This is an automated email from the ASF dual-hosted git repository. zhijiang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6126600 [FLINK-16261][table] Use type compatibility consistently to avoid casting add 3b99f7e [FLINK-16554][task][refactoring] split StreamTask No new revisions were added by this update. Summary of changes: .../runtime/tasks/AsyncCheckpointRunnable.java | 256 +++++++++++++++ .../runtime/tasks/CheckpointingOperation.java | 136 ++++++++ .../flink/streaming/runtime/tasks/StreamTask.java | 355 +-------------------- .../runtime/tasks/LocalStateForwardingTest.java | 16 +- 4 files changed, 409 insertions(+), 354 deletions(-) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CheckpointingOperation.java