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(-)
