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 f6f51d8 Revert "[FLINK-17800][roksdb] Ensure total order seek to
avoid user misuse"
add 03beab8 [FLINK-18094][network] Fixed UnionInputGate#getChannel.
add 485688f [FLINK-18094][network] Add InputGate#getChannelInfos for
easier testing.
add 49a36f5 [FLINK-18094][network] Simplifying InputProcessorUtil by
delegating createCheckpointedInputGate to createCheckpointedMultipleInputGate.
add 70e3c88 [FLINK-18094][network] Using lists instead of collections of
gates while creating checkpoint handlers.
add 1bacaee [FLINK-18094][network] Buffers are only addressed through
InputChannelInfo.
No new revisions were added by this update.
Summary of changes:
.../network/api/reader/AbstractRecordReader.java | 22 ++--
.../network/partition/consumer/BufferOrEvent.java | 33 +++---
.../io/network/partition/consumer/InputGate.java | 13 +++
.../partition/consumer/SingleInputGate.java | 4 +-
.../network/partition/consumer/UnionInputGate.java | 41 +++----
.../io/network/api/writer/RecordWriterTest.java | 5 +-
.../partition/consumer/InputGateTestBase.java | 2 +-
.../partition/consumer/LocalInputChannelTest.java | 4 +-
.../partition/consumer/SingleInputGateBuilder.java | 24 ++++-
.../partition/consumer/SingleInputGateTest.java | 19 ++--
.../partition/consumer/UnionInputGateTest.java | 18 ++++
.../io/AlternatingCheckpointBarrierHandler.java | 8 +-
.../runtime/io/CheckpointBarrierAligner.java | 81 +++++++-------
.../runtime/io/CheckpointBarrierHandler.java | 6 +-
.../runtime/io/CheckpointBarrierTracker.java | 5 +-
.../runtime/io/CheckpointBarrierUnaligner.java | 80 +++++---------
.../runtime/io/CheckpointedInputGate.java | 49 ++-------
.../flink/streaming/runtime/io/InputGateUtil.java | 19 +---
.../streaming/runtime/io/InputProcessorUtil.java | 118 +++++----------------
.../runtime/io/StreamTaskNetworkInput.java | 25 ++++-
.../runtime/tasks/AbstractTwoInputStreamTask.java | 5 +-
.../runtime/tasks/MultipleInputStreamTask.java | 3 +-
.../runtime/tasks/TwoInputStreamTask.java | 6 +-
.../AlternatingCheckpointBarrierHandlerTest.java | 45 ++++----
.../CheckpointBarrierAlignerMassiveRandomTest.java | 18 +++-
.../io/CheckpointBarrierAlignerTestBase.java | 12 ++-
.../runtime/io/CheckpointBarrierTrackerTest.java | 7 +-
...CheckpointBarrierUnalignerCancellationTest.java | 5 +-
.../runtime/io/CheckpointBarrierUnalignerTest.java | 50 ++++-----
.../CreditBasedCheckpointBarrierAlignerTest.java | 2 +-
.../runtime/io/InputProcessorUtilTest.java | 34 +-----
.../streaming/runtime/io/MockIndexedInputGate.java | 11 ++
.../flink/streaming/runtime/io/MockInputGate.java | 12 ++-
.../runtime/io/StreamTaskNetworkInputTest.java | 27 ++---
34 files changed, 378 insertions(+), 435 deletions(-)
