Open Hub
Black Duck Open Hub

 Settings |  Report Duplicate

9
I Use This!
Very High Activity

Commits : Listings

Analyzed about 12 hours ago. based on code collected about 16 hours ago.
Mar 20, 2024 — Apr 19, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
[FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment
Chesnay Schepler
More... 1 day ago
[hotfix] Delete pointless test
Chesnay Schepler
More... 1 day ago
[FLINK-35045][state] Support ByteBufferReadable for HadoopDataInputStream
Hangxiang Yu
More... 2 days ago
[FLINK-35045][state] Introduce ByteBufferReadable to support reading and positionable reading with ByteBuffer
Hangxiang Yu
More... 2 days ago
[FLINK-34633][table] Support unnesting array constants
Jeyhun Karimov
More... 2 days ago
[FLINK-34987][state] Implement Async Value State (#24651)
Hangxiang Yu
More... 3 days ago
[FLINK-34987][state] Introduce InternalKeyedState for Async State API
Hangxiang Yu
More... 3 days ago
[FLINK-34987][state] Introduce new StateDescriptor for Async State API
Hangxiang Yu
More... 3 days ago
[FLINK-25537][JUnit5 Migration] Module flink-core with package configuration
gongzhongqiang
More... 4 days ago
[FLINK-35025][Runtime/State] Introduce element order for async state processing
Zakelly
More... 5 days ago
[FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24481)
Ahmed Hamdy
More... 5 days ago
[hotfix][runtime]Fix the missing methed parameter annotation problem
chenyu
More... 5 days ago
[FLINK-34158][table] Migrate WindowAggregateReduceFunctionsRule to java
Sergey Nuyanzin
More... 5 days ago
[FLINK-32440][checkpoint] Introduce file merging configuration (#22973)
Yanfei Lei
More... 5 days ago
[FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController (#24633)
Yanfei Lei
More... 5 days ago
[FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor (#24663)
Hangxiang Yu
More... 5 days ago
[FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor
Mingliang Liu
More... 7 days ago
[FLINK-35025][Runtime/State] Abstract stream operators for async state processing
Zakelly
More... 8 days ago
[FLINK-35025][Runtime/State] Erase the type parameter of record within AEC and related components.
Zakelly
More... 8 days ago
[FLINK-35089][runtime] Initialize lastRecordAttributes in AbstractStreamOperator during setup
sxnan
More... 8 days ago
[FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework
Zakelly
More... 9 days ago
[hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions (#24629)
Zakelly
More... 9 days ago
[FLINK-35015][formats] allow passing hadoop config into parquet reader (#24623)
Peter Huang
More... 10 days ago
[FLINK-35023][tests] Use surefire.module.config in yarn-test
Ryan Skraba
More... 10 days ago
[FLINK-34250][docs] add new option for avro format docs
Zhenqiu Huang
More... 10 days ago
[FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window
Jinzhong Li
More... 11 days ago
[FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager
Zakelly
More... 11 days ago
fixup! [FLINK-19010][metric] Introduce subtask level restore metric
Piotr Nowojski
More... 11 days ago
[FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization
fredia
More... 11 days ago
[FLINK-34649][table] Migrate PushFilterIntoLegacyTableSourceScanRule to java
Jacky Lau
More... 12 days ago