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/21 19:09:13 UTC

[flink] branch master updated (303e008 -> c9fd502)

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 303e008  [FLINK-17258][hotfix][network] Unify checkpoint id logging with CheckpointCoordinator
     add 2efa2ed  [FLINK-17805][hotfix][network] Fix/update/rename InputProcessorUtil.createCheckpointedInputGatePair method
     add c9fd502  [FLINK-17805][network] Fix ArrayIndexOutOfBound for rotated input gate indexes

No new revisions were added by this update.

Summary of changes:
 .../runtime/io/CheckpointedInputGate.java          |  5 ++
 .../streaming/runtime/io/InputProcessorUtil.java   | 20 ++++++-
 .../runtime/tasks/MultipleInputStreamTask.java     |  2 +-
 .../runtime/tasks/TwoInputStreamTask.java          |  2 +-
 .../runtime/io/InputProcessorUtilTest.java         | 61 ++++++++++++++++++++++
 .../streaming/runtime/io/MockIndexedInputGate.java | 12 ++++-
 6 files changed, 96 insertions(+), 6 deletions(-)