This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 07ea97cd1ae [FLINK-37137][runtime] Fix unstable test
testGenerateStreamGraphJson (#25990)
new e3c28414a75 [FLINK-35412][Runtime] Remove `BatchCallbackRunner`
new e9d9cb2278e [FLINK-37017][Runtime] Allow buffer overdraft in async
state processing
new fc57f0daa42 [FLINK-37017][Runtime] Drain in best efforts when allowing
overdraft
new 9da368d6cb1 [FLINK-37017][Runtime] Prevent stack overflow when
draining in-flight records
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../asyncprocessing/AsyncExecutionController.java | 162 +++++++++++++++------
.../asyncprocessing/BatchCallbackRunner.java | 148 -------------------
.../asyncprocessing/CallbackRunnerWrapper.java | 73 ++++++++++
.../asyncprocessing/StateFutureFactory.java | 4 +-
.../asyncprocessing/StateRequestBuffer.java | 5 +-
.../AbstractAsyncStateStreamOperator.java | 4 +-
.../AbstractAsyncStateStreamOperatorV2.java | 4 +-
.../operators/InternalTimerServiceAsyncImpl.java | 9 +-
.../AsyncExecutionControllerTest.java | 41 +++++-
...nerTest.java => CallbackRunnerWrapperTest.java} | 29 +---
10 files changed, 243 insertions(+), 236 deletions(-)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/BatchCallbackRunner.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/CallbackRunnerWrapper.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/asyncprocessing/{BatchCallbackRunnerTest.java
=> CallbackRunnerWrapperTest.java} (73%)
