9
I Use This!
Very High Activity

Commits : Listings

Analyzed about 1 hour ago. based on code collected about 3 hours ago.
May 13, 2023 — May 13, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
[FLINK-35168][State] Basic State Iterator for async processing (#24690) More... about 3 hours ago
[FLINK-35302][rest] Ignore unknown fields in REST request deserialization More... about 8 hours ago
[FLINK-35198][table] Support manual refresh materialized table More... 2 days ago
[hotfix][test] Fix InstantiationUtilTest cannot find assertFalse More... 2 days ago
[FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: util (#24670) More... 2 days ago
[FLINK-35112][python] Correct contains check for Row type (#24756) More... 3 days ago
[FLINK-35041][test] Fix the IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed More... 3 days ago
[FLINK-35197][table] Support the execution of suspend, resume materialized table in continuous refresh mode More... 4 days ago
[FLINK-35197][table] Support convert alter materialized table suspend/resume nodes to operations More... 4 days ago
[FLINK-35197][table] Fix incomplete serialization and deserialization of materialized tables More... 4 days ago
[FLINK-34916][table] Support `ALTER CATALOG SET` syntax More... 5 days ago
[FLINK-35270]Enrich information in logs, making it easier for debugging More... 5 days ago
[FLINK-35306][test] Migrate flink-tests-java17 module to JUnit5 and assertj to solve jdk17 compile fails More... 5 days ago
[FLINK-25537] [JUnit5 Migration] Migrate the api package of flink-core module to JUnit5 More... 6 days ago
[FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 (#24732) More... 7 days ago
[FLINK-35195][table] Support execute CreateMaterializedTableOperation for continuous refresh mode in SqlGateway More... 7 days ago
[FLINK-35195][table] Introduce DropMaterializedTableOperation to support drop materialized table More... 7 days ago
[FLINK-35195][table] Introduce MaterializedTableChange to support update materialized table refresh status and RefreshHandler More... 7 days ago
[FLINK-35195][table] Introduce ContinuousRefreshHandler and serializer for continuous refresh mode More... 7 days ago
[FLINK-35195][table] Convert SqlCreateMaterializedTable node to CreateMaterializedTableOperation More... 7 days ago
[FLINK-35195][table] Convert CatalogMaterializedTable to CatalogTable to generate execution plan for planner More... 7 days ago
[FLINK-35195][table] Introduce materialized table reflated config options More... 7 days ago
[FLINK-35155] Introduce TableRuntimeException (#24679) More... 7 days ago
[FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 More... 8 days ago
[FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) More... 13 days ago
[FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES More... 13 days ago
[FLINK-35195][test/test-filesystem] test-filesystem Catalog support create generic table More... 13 days ago
[FLINK-35232] Add retry settings for GCS connector More... 14 days ago
[FLINK-35048][state] Support AsyncKeyedStateBackend for ForStKeyedStateBackend More... 14 days ago
[FLINK-35262][state] Bridge between AsyncKeyedStateBackend and AsyncExecutionController More... 14 days ago