This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3e1b2b7 [FLINK-18289][Checkpoint] Ensure notifyCheckpointAborted
interface work in UDF operator
new 75c0b5b [FLINK-18094][network] Fixed UnionInputGate#getChannel.
new b399a14 [FLINK-18094][network] Add InputGate#getChannelInfos for
easier testing.
new 33b8600 [FLINK-18094][network] Simplifying InputProcessorUtil by
delegating createCheckpointedInputGate to createCheckpointedMultipleInputGate.
new fb3eeb18 [FLINK-18094][network] Using lists instead of collections of
gates while creating checkpoint handlers.
new 1d211b9 [FLINK-18094][network] Buffers are only addressed through
InputChannelInfo.
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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(-)
