Open Hub
Black Duck Open Hub

 Settings |  Report Duplicate

9
I Use This!
Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.
Apr 23, 2023 — Apr 23, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
[FLINK-35158][Core/API] Move functional interfaces about consumers from core module to core-api
Zakelly
More... 1 day ago
[FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated
Yuxin Tan
More... 1 day ago
[FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode (#24303)
Ferenc Csaky
More... 4 days ago
[FLINK-35175][filesystem] Avoid reading with ByteBuffer on hadoop version below 3.3.0 (#24691)
Hangxiang Yu
More... 5 days ago
[FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (#23777)
Alexander Fedulov
More... 5 days ago
[FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator
Yuxin Tan
More... 6 days ago
[FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment
Chesnay Schepler
More... 6 days ago
[hotfix] Delete pointless test
Chesnay Schepler
More... 6 days ago
[FLINK-35097][table] Use var-args in RawFormatSerDeSchemaTest
Kumar Mallikarjuna
More... 7 days ago
[FLINK-35045][state] Support ByteBufferReadable for HadoopDataInputStream
Hangxiang Yu
More... 7 days ago
[FLINK-35045][state] Introduce ByteBufferReadable to support reading and positionable reading with ByteBuffer
Hangxiang Yu
More... 7 days ago
[FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController
fredia
More... 7 days ago
[FLINK-34633][table] Support unnesting array constants
Jeyhun Karimov
More... 7 days ago
[FLINK-34987][state] Implement Async Value State (#24651)
Hangxiang Yu
More... 8 days ago
[FLINK-34987][state] Introduce InternalKeyedState for Async State API
Hangxiang Yu
More... 8 days ago
[FLINK-34987][state] Introduce new StateDescriptor for Async State API
Hangxiang Yu
More... 8 days ago
[FLINK-35028][runtime] Timer firing under async execution model
fredia
More... 9 days ago
[FLINK-25537][JUnit5 Migration] Module flink-core with package configuration
gongzhongqiang
More... 9 days ago
[FLINK-35025][Runtime/State] Introduce element order for async state processing
Zakelly
More... 9 days ago
[FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24481)
Ahmed Hamdy
More... 9 days ago
[hotfix][runtime]Fix the missing methed parameter annotation problem
chenyu
More... 10 days ago
[FLINK-34158][table] Migrate WindowAggregateReduceFunctionsRule to java
Sergey Nuyanzin
More... 10 days ago
[FLINK-32440][checkpoint] Introduce file merging configuration (#22973)
Yanfei Lei
More... 10 days ago
[FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController (#24633)
Yanfei Lei
More... 10 days ago
[FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor (#24663)
Hangxiang Yu
More... 10 days ago
[FLINK-35097][table] Update RawFormatSerDeSchemaTest to validate multiple serializations/deserializations
Kumar Mallikarjuna
More... 10 days ago
[FLINK-35097][table] Fix 'raw' format deserialization
Kumar Mallikarjuna
More... 10 days ago
[FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor
Mingliang Liu
More... 12 days ago
[FLINK-35025][Runtime/State] Abstract stream operators for async state processing
Zakelly
More... 12 days ago
[FLINK-35025][Runtime/State] Erase the type parameter of record within AEC and related components.
Zakelly
More... 13 days ago