[flink] branch master updated (0d0fce2 -> 3ed4930)

[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 0d0fce2  [FLINK-19105][docs] Fix documentation errors about FileSystem usage
     add 66e7ab5  [FLINK-18904][hotfix] Sort methods in StreamConfig
     add c303a37  [FLINK-18904][hotfix] Remove unused methods in StreamConfig
     add 69ae2e1  [FLINK-18904][task] Migrate input serializers to inputs in StreamConfig
     add 6944995  [FLINK-18904][task] Rename NumberOfInputs to NumberOfNetworkInputs in StreamConfig
     add 2610905  [FLINK-18905][task] Rename headOperator to mainOperator
     add 241e64b  [FLINK-18905][hotfix][task] Extract OperatorChain#createChainOutputs method
     add aa0b62c  [FLINK-18905][hotfix][task] Rename OperatorChain#chainEntryPoint to mainOperatorOutput
     add 3e50e3f  [FLINK-18905][hotfix][task] Move output and collector helper classes out of OperatorChain
     add ee4cdf6  [FLINK-18905][hotfix][task/test] Use StreamConfigChainer for setupOutputForSingletonOperatorChain
     add bc573fb  [FLINK-18905][hotfix] Extract common OutputTag#isResponsibleFor with explicit Nonnull check
     add 7f7d423  [FLINK-18905][task/datastream] Convert OneInputStreamOperator to Input
     add 7f7a6dd  [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask
     add 556efa4  [FLINK-18905][hotfix][task] Simplify exception handling in StreamTask#dispatchOperatorEvent
     add 3ed4930  [hotfix][task] Add SuppressWarnings to StreamMultipleInputProcessor

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/flink/util/OutputTag.java |  18 +-
 .../api/connector/source/mocks/MockSource.java     |   2 +-
 .../flink/state/api/output/BoundedStreamTask.java  |  18 +-
 .../api/collector/selector/DirectedOutput.java     |   4 +-
 .../flink/streaming/api/graph/StreamConfig.java    | 187 ++++---
 .../api/graph/StreamingJobGraphGenerator.java      |   2 +-
 .../api/operators/OneInputStreamOperator.java      |  24 +-
 .../streaming/api/operators/StreamSource.java      |   2 +-
 .../streaming/runtime/io/RecordWriterOutput.java   |  12 +-
 .../runtime/io/StreamMultipleInputProcessor.java   |  96 ++--
 .../runtime/io/StreamOneInputProcessor.java        |   2 +-
 .../runtime/io/StreamTwoInputProcessor.java        |   2 +-
 .../runtime/tasks/AbstractTwoInputStreamTask.java  |   8 +-
 .../runtime/tasks/BroadcastingOutputCollector.java |  93 ++++
 .../streaming/runtime/tasks/ChainingOutput.java    | 158 ++++++
 .../tasks/CopyingBroadcastingOutputCollector.java  |  66 +++
 .../runtime/tasks/CopyingChainingOutput.java       |  92 ++++
 .../runtime/tasks/MultipleInputStreamTask.java     |  33 +-
 .../runtime/tasks/OneInputStreamTask.java          |   8 +-
 .../streaming/runtime/tasks/OperatorChain.java     | 593 ++++++++-------------
 .../runtime/tasks/SourceOperatorStreamTask.java    |   8 +-
 .../streaming/runtime/tasks/SourceStreamTask.java  |  10 +-
 .../runtime/tasks/StreamIterationTail.java         |   2 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  |  18 +-
 .../tasks/SubtaskCheckpointCoordinatorImpl.java    |   2 +-
 .../runtime/tasks/TwoInputStreamTask.java          |   6 +-
 ...info.java => WatermarkGaugeExposingOutput.java} |  19 +-
 .../operators/StreamOperatorChainingTest.java      |   4 +-
 .../MultipleInputStreamTaskChainedSourcesTest.java | 242 +++++++++
 .../runtime/tasks/MultipleInputStreamTaskTest.java |  13 +-
 .../runtime/tasks/OneInputStreamTaskTest.java      |   1 +
 .../tasks/OneInputStreamTaskTestHarness.java       |   2 +-
 .../streaming/runtime/tasks/OperatorChainTest.java |   3 -
 .../tasks/SourceOperatorStreamTaskTest.java        |   2 +-
 .../runtime/tasks/StreamConfigChainer.java         |  51 +-
 .../tasks/StreamTaskMailboxTestHarnessBuilder.java | 169 ++++--
 .../streaming/runtime/tasks/StreamTaskTest.java    |   4 +-
 .../runtime/tasks/StreamTaskTestHarness.java       |   2 +-
 .../tasks/TwoInputStreamTaskTestHarness.java       |   2 +-
 39 files changed, 1354 insertions(+), 626 deletions(-)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/BroadcastingOutputCollector.java
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ChainingOutput.java
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CopyingBroadcastingOutputCollector.java
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.java
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/{package-info.java => WatermarkGaugeExposingOutput.java} (66%)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTaskChainedSourcesTest.java