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 476e5af [FLINK-19288] Make the InternalTimeServiceManager an interface
add 21a0ed8 [FLINK-18906][hotfix] Fix JavaDoc for in InputProcessorUtil
add 46251fe [FLINK-18906][hotfix] Move isFinished checkState inside
InputGate#resumeConsumption
add aa75291 [FLINK-18906][hotfix] Fix method names in
CheckpointBarrierAlignerTestBase
add 72bec38 [FLINK-18906][task] Construct StreamTaskSourceInput earlier
in the OperatorChain
add f7adc87 [FLINK-18906][task] Decouple CheckpointBarrierHandlers from
InputGates
add 2f71191 [FLINK-18906][hotfix] Provide helper and/or functions on
availability futures
add 187747b [FLINK-18906][task] Fix processSingleStep semantic
add a531294 [FLINK-18906][test] Generalise testing code for
MultipleInputStreamTask
add 1bc7fde [FLINK-18906][task] Expose
InputProcessorUtil#createCheckpointBarrierHandler
add f547f4c [FLINK-18906][task] Support StreamTaskSourceInput as
BlockabledInput
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/io/AvailabilityProvider.java | 38 ++++
.../runtime/io/network/buffer/LocalBufferPool.java | 5 +-
.../partition/consumer/CheckpointableInput.java | 26 ++-
.../partition/consumer/IndexedInputGate.java | 28 ++-
.../partition/consumer/SingleInputGate.java | 1 +
.../runtime/io/CheckpointBarrierAligner.java | 23 +-
.../runtime/io/CheckpointBarrierUnaligner.java | 28 ++-
.../streaming/runtime/io/InputProcessorUtil.java | 57 +++--
.../runtime/io/StreamMultipleInputProcessor.java | 5 +-
.../runtime/io/StreamTaskSourceInput.java | 88 +++++++-
.../runtime/io/StreamTwoInputProcessor.java | 4 +-
.../runtime/tasks/MultipleInputStreamTask.java | 114 +++++++++-
.../streaming/runtime/tasks/OperatorChain.java | 35 ++-
.../runtime/tasks/SourceOperatorStreamTask.java | 2 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 5 +
.../runtime/tasks/TwoInputStreamTask.java | 5 +-
.../runtime/tasks/mailbox/MailboxProcessor.java | 48 +++--
.../CheckpointBarrierAlignerMassiveRandomTest.java | 9 +-
.../io/CheckpointBarrierAlignerTestBase.java | 42 ++--
...CheckpointBarrierUnalignerCancellationTest.java | 4 +-
.../runtime/io/CheckpointBarrierUnalignerTest.java | 7 +-
.../CreditBasedCheckpointBarrierAlignerTest.java | 4 +-
.../runtime/io/InputProcessorUtilTest.java | 3 +-
.../flink/streaming/runtime/io/MockInputGate.java | 8 +-
...tStreamTaskChainedSourcesCheckpointingTest.java | 240 +++++++++++++++++++++
.../MultipleInputStreamTaskChainedSourcesTest.java | 47 ++--
.../runtime/tasks/MultipleInputStreamTaskTest.java | 46 ++--
.../tasks/StreamTaskMailboxTestHarness.java | 17 +-
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 5 +
...treamTaskMultipleInputSelectiveReadingTest.java | 12 +-
30 files changed, 775 insertions(+), 181 deletions(-)
copy
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/NoOpCassandraFailureHandler.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/CheckpointableInput.java
(55%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTaskChainedSourcesCheckpointingTest.java
