[flink] branch master updated (add08a6 -> d38bd89)

[pn...@apache.org]

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