9
I Use This!
Very High Activity

Commits : Listings

Analyzed about 13 hours ago. based on code collected 1 day ago.
Apr 17, 2023 — Apr 17, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
[FLINK-25537][JUnit5 Migration] Module flink-core with package configuration More... 2 days ago
[FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24481) More... 3 days ago
[hotfix][runtime]Fix the missing methed parameter annotation problem More... 3 days ago
[FLINK-34158][table] Migrate WindowAggregateReduceFunctionsRule to java More... 3 days ago
[FLINK-32440][checkpoint] Introduce file merging configuration (#22973) More... 3 days ago
[FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController (#24633) More... 3 days ago
[FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor More... 5 days ago
[FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework More... 7 days ago
[hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions (#24629) More... 7 days ago
[FLINK-35015][formats] allow passing hadoop config into parquet reader (#24623) More... 8 days ago
[FLINK-35023][tests] Use surefire.module.config in yarn-test More... 8 days ago
[FLINK-34250][docs] add new option for avro format docs More... 8 days ago
[FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window More... 9 days ago
fixup! [FLINK-19010][metric] Introduce subtask level restore metric More... 9 days ago
[FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization More... 9 days ago
[FLINK-34649][table] Migrate PushFilterIntoLegacyTableSourceScanRule to java More... 10 days ago
[FLINK-34161][table] Migration of RewriteMinusAllRule to java More... 10 days ago
[FLINK-34556][table] Migrate EnumerableToLogicalTableScan to java More... 10 days ago
[FLINK-34159][table] Migrate ConstantRankNumberColumnRemoveRule to java More... 10 days ago
[FLINK-34162][table] Migrate LogicalUnnestRule to java More... 10 days ago
[FLINK-35044][state] Init flink-statebackend-forst module More... 10 days ago
[FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 More... 11 days ago
[FLINK-34986][Runtime/State] More tests for reference counting of ContextStateFutureImpl More... 11 days ago
[FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax More... 11 days ago
[FLINK-35011][tests] Change MockDeserializationSchema's visibility back to public to prevent compilation failure in external connectors More... 12 days ago
[FLINK-34657] add lineage provider API (#24619) More... 13 days ago
[FLINK-35021] AggregateQueryOperations produces wrong asSerializableString representation (#24624) More... 13 days ago
[hotfix] Log Job ID when task is failed externally More... 13 days ago
[FLINK-34025] Add data skew metric endpoint and UI More... 14 days ago
[FLINK-35000][build] Updates link to test code convention in pull request template More... 15 days ago