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 add08a6 [FLINK-19377] Change parameters of
EventTimeWindowCheckpointingITCase
add d922f86 [FLINK-18907][test] Move
MultipleInputStreamTaskChainedSourcesTest to MultipleInputStreamTaskTest
add 30185a5 [FLINK-18907][task] Fix too many endInput calls with chained
sources
add 52e14d5 [FLINK-18907][test] Remove now duplicated
testClosingAllOperatorsOnChainProperly test
add d3d491b [FLINK-18907][task] Fix numRecordsIn metric with chained
sources
add 3bf4edf [FLINK-18907][test] Refactor MockSourceReader
add f765511 [FLINK-18907][task] Add test coverage for watermarks with
chained sources
add 90e86ea [FLINK-18907][hotfix] Rename headOperator to mainOperator in
the MultipleInputStreamTaskTest
add cf1b21f [FLINK-18907][hotfix] Replace old processIf/WhileAvailable
with processSingleStep
add 8ec9f1d [FLINK-18907][task] Fix and add test coverage for watermarks
gauges with chained sources
add f60a53f [FLINK-18907][hotfix] Fix the
testWatermarkAndStreamStatusForwarding to do what it was intended to do
add d38bd89 [FLINK-18907][test] Add stream status forwarding test for
chained sources
No new revisions were added by this update.
Summary of changes:
.../api/connector/source/mocks/MockSource.java | 10 +-
.../connector/source/mocks/MockSourceReader.java | 76 ++-
.../metrics/groups/OperatorIOMetricGroup.java | 1 -
.../api/operators/AbstractStreamOperator.java | 3 -
.../api/operators/AbstractStreamOperatorV2.java | 3 -
.../runtime/io/StreamMultipleInputProcessor.java | 49 +-
.../runtime/io/StreamTwoInputProcessor.java | 34 +-
.../runtime/tasks/MultipleInputStreamTask.java | 5 +-
.../runtime/tasks/OneInputStreamTask.java | 8 +-
.../streaming/runtime/tasks/OperatorChain.java | 26 +-
.../runtime/tasks/SourceOperatorStreamTask.java | 18 +-
.../runtime/tasks/StreamOperatorWrapper.java | 36 +-
.../runtime/tasks/TwoInputStreamTask.java | 1 +
...tStreamTaskChainedSourcesCheckpointingTest.java | 12 +-
.../MultipleInputStreamTaskChainedSourcesTest.java | 249 ----------
.../runtime/tasks/MultipleInputStreamTaskTest.java | 517 +++++++++++++++------
.../streaming/runtime/tasks/OperatorChainTest.java | 6 +-
.../runtime/tasks/StreamConfigChainer.java | 5 +
.../runtime/tasks/StreamOperatorWrapperTest.java | 6 +-
.../tasks/StreamTaskMailboxTestHarness.java | 19 +-
...treamTaskMultipleInputSelectiveReadingTest.java | 12 +-
21 files changed, 590 insertions(+), 506 deletions(-)
delete mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTaskChainedSourcesTest.java
