You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by zh...@apache.org on 2020/03/13 12:58:54 UTC

[flink] branch master updated (6126600 -> 3b99f7e)

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