Apache Flink

Settings | Report Duplicate

9

I Use This!

Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
May 14, 2023 — May 14, 2024 Showing page 1 of 63 Search / Filter on:
[FLINK-32087][checkpoint] Introduce space amplification statistics of file merging (#24762)	Yanfei Lei	More...				2 days ago
[FLINK-35098][ORC] Fix incorrect results with literal first expressions	Andrey Gaskov	More...				2 days ago
[FLINK-35342][table] Fix MaterializedTableStatementITCase test can check for wrong status	Feng Jin	More...				2 days ago
[FLINK-35168][State] Basic State Iterator for async processing (#24690)	Zakelly	More...				3 days ago
[FLINK-35193][table] Support execution of drop materialized table	Feng Jin	More...				3 days ago
[FLINK-35193][table] Support convert drop materialized table node to operation	Feng Jin	More...				3 days ago
[FLINK-35193][table] Support drop materialized table syntax	Feng Jin	More...				3 days ago
[FLINK-35302][rest] Ignore unknown fields in REST request deserialization	Juntao Hu	More...				3 days ago
[FLINK-35198][table] Support manual refresh materialized table	Xuyang	More...				5 days ago
[hotfix][test] Fix InstantiationUtilTest cannot find assertFalse	Rui Fan	More...				5 days ago
[FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: util (#24670)	gongzhongqiang	More...				5 days ago
[FLINK-35112][python] Correct contains check for Row type (#24756)	Wouter Zorgdrager	More...				5 days ago
[FLINK-35041][test] Fix the IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed	Rui Fan	More...				6 days ago
[FLINK-35197][table] Support the execution of suspend, resume materialized table in continuous refresh mode	Feng Jin	More...				7 days ago
[FLINK-35197][table] Support convert alter materialized table suspend/resume nodes to operations	Feng Jin	More...				7 days ago
[FLINK-35197][table] Fix incomplete serialization and deserialization of materialized tables	Feng Jin	More...				7 days ago
[FLINK-34916][table] Support `ALTER CATALOG SET` syntax	Yubin Li	More...				7 days ago
[FLINK-35270]Enrich information in logs, making it easier for debugging	HCTommy	More...				8 days ago
[FLINK-35306][test] Migrate flink-tests-java17 module to JUnit5 and assertj to solve jdk17 compile fails	Rui Fan	More...				8 days ago
[FLINK-25537] [JUnit5 Migration] Migrate the api package of flink-core module to JUnit5	gongzhongqiang	More...				9 days ago
[FLINK-35293][hive] Hive source supports dynamic parallelism inference	sunxia	More...				9 days ago
[FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 (#24732)	Yuepeng Pan	More...				10 days ago
[FLINK-35195][table] Support execute CreateMaterializedTableOperation for continuous refresh mode in SqlGateway	fengli	More...				10 days ago
[FLINK-35195][table] Introduce DropMaterializedTableOperation to support drop materialized table	fengli	More...				10 days ago
[FLINK-35195][table] Introduce MaterializedTableChange to support update materialized table refresh status and RefreshHandler	fengli	More...				10 days ago
[FLINK-35195][table] Introduce ContinuousRefreshHandler and serializer for continuous refresh mode	fengli	More...				10 days ago
[FLINK-35195][table] Convert SqlCreateMaterializedTable node to CreateMaterializedTableOperation	fengli	More...				10 days ago
[FLINK-35195][table] Convert CatalogMaterializedTable to CatalogTable to generate execution plan for planner	fengli	More...				10 days ago
[FLINK-35195][table] Introduce materialized table reflated config options	fengli	More...				10 days ago
[FLINK-35155] Introduce TableRuntimeException (#24679)	Dawid Wysakowicz	More...				10 days ago

←
1
2
3
4
5
6
7
8
9
…
62
63
→