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/06/23 15:55:07 UTC

[flink] branch master updated (1414bac -> a32c99d)

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 1414bac  [FLINK-18399][table-api-java] Fix TableResult#print can not print the result of unbounded stream query
     add a32c99d  [FLINK-18348] RemoteInputChannel should checkError before checking partitionRequestClient

No new revisions were added by this update.

Summary of changes:
 .../network/partition/consumer/BufferManager.java  |  6 ++++-
 .../network/partition/consumer/InputChannel.java   |  4 ++--
 .../io/network/partition/consumer/InputGate.java   |  2 +-
 .../partition/consumer/RemoteInputChannel.java     | 26 ++++++++++++----------
 .../partition/consumer/SingleInputGate.java        |  2 +-
 .../network/partition/consumer/UnionInputGate.java |  2 +-
 .../runtime/taskmanager/InputGateWithMetrics.java  |  2 +-
 .../partition/consumer/RemoteInputChannelTest.java | 12 ++++++++++
 .../io/AlternatingCheckpointBarrierHandler.java    |  2 +-
 .../runtime/io/CheckpointBarrierAligner.java       |  8 +++----
 .../runtime/io/CheckpointBarrierHandler.java       |  2 +-
 11 files changed, 43 insertions(+), 25 deletions(-)