This is an automated email from the ASF dual-hosted git repository.
leiyanfei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 714d1cb2e0b [FLINK-35189][test-utils] Introduce test-filesystem
connector and catalog based on filesystem to support materialized table
add 713c30f76d5 [FLINK-35026][runtime][config] Introduce async execution
configurations
add 3ff2ba43720 [FLINK-35026][runtime] Implement buffer timeout of AEC
No new revisions were added by this update.
Summary of changes:
.../apache/flink/api/common/ExecutionConfig.java | 38 +++++
.../flink/configuration/ExecutionOptions.java | 59 +++++++
.../asyncprocessing/AsyncExecutionController.java | 48 +++---
.../asyncprocessing/StateRequestBuffer.java | 83 +++++++++-
.../AsyncExecutionControllerTest.java | 182 +++++++++++++++++----
.../AbstractAsyncStateStreamOperator.java | 23 ++-
.../AbstractAsyncStateStreamOperatorV2.java | 18 +-
.../StreamExecutionEnvironmentTest.java | 30 ++++
.../InternalTimerServiceAsyncImplTest.java | 2 +-
9 files changed, 418 insertions(+), 65 deletions(-)
