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

Posted to commits@flink.apache.org by pn...@apache.org on 2020/05/16 08:45:34 UTC

[flink] branch master updated (084b4b2 -> 2b42209)

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 084b4b2  post-rebase fixup! [FLINK-17350][task] Fail task immediately if synchronous part snapshotState throws an exception
     add 909a13d  [hotfix][checkpointing] Fix the invalid argument in constuctor of CheckpointCoordinatorConfiguration
     add 2b42209  [FLINK-17719][task][checkpointing] Provide ChannelStateReader#hasStates for hints of reading channel states

No new revisions were added by this update.

Summary of changes:
 .../checkpoint/channel/ChannelStateReader.java     | 10 ++++
 .../checkpoint/channel/ChannelStateReaderImpl.java |  5 ++
 .../tasks/CheckpointCoordinatorConfiguration.java  |  4 +-
 .../flink/runtime/state/TaskStateManagerImpl.java  |  2 +-
 .../io/network/partition/ResultPartitionTest.java  | 10 ++++
 .../flink/streaming/runtime/tasks/StreamTask.java  | 11 ++--
 .../streaming/runtime/tasks/StreamTaskTest.java    | 58 ++++++++++++++++++----
 7 files changed, 82 insertions(+), 18 deletions(-)