You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/03/26 06:56:08 UTC
[flink] branch master updated (b17d01b -> 1d5f447)
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 b17d01b [FLINK-16480][e2e] On failure, add e2e logs into artifact
add 5b3d4eb [hotfix][tests] Remove dead code
add 158e447 [FLINK-16317][operators] Provide support for watermarks in MultipleInputStreamOperator
add a443b04 [FLINK-16317][operators] Refactor AbstractStreamOperatorTest class
add 381a01a [FLINK-16317][operators] Implement AbstractStreamOperatorV2Test
add 05883b7 [FLINK-16317][operators] Provide support for key selector and latency marker in MultipleInputStreamOperator
add 1d5f447 [FLINK-16317][operators] return this from (Keyed)MultipleInputTransformation#addInput
No new revisions were added by this update.
Summary of changes:
.../api/datastream/MultipleConnectedStreams.java | 4 +-
.../flink/streaming/api/graph/StreamGraph.java | 11 +-
.../streaming/api/graph/StreamGraphGenerator.java | 15 +-
.../flink/streaming/api/graph/StreamNode.java | 20 +-
.../api/graph/StreamingJobGraphGenerator.java | 5 +-
.../streaming/api/operators/AbstractInput.java | 71 ++++
.../api/operators/AbstractStreamOperatorV2.java | 2 +-
.../flink/streaming/api/operators/Input.java | 20 +
...va => AbstractMultipleInputTransformation.java} | 15 +-
.../KeyedMultipleInputTransformation.java | 61 +++
.../MultipleInputTransformation.java | 57 +--
.../runtime/io/StreamMultipleInputProcessor.java | 17 +-
.../runtime/tasks/MultipleInputStreamTask.java | 2 +-
.../apache/flink/streaming/api/DataStreamTest.java | 10 +-
.../api/graph/StreamGraphGeneratorTest.java | 8 +-
.../api/operators/AbstractStreamOperatorTest.java | 451 ++++++++++-----------
.../operators/AbstractStreamOperatorV2Test.java | 136 +++++++
.../runtime/tasks/MultipleInputStreamTaskTest.java | 323 +++++++++++++--
.../MultipleInputStreamTaskTestHarnessBuilder.java | 11 +
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 5 +
.../runtime/tasks/TwoInputStreamTaskTest.java | 2 +-
.../KeyedOneInputStreamOperatorTestHarness.java | 24 +-
.../util/OneInputStreamOperatorTestHarness.java | 73 +++-
.../util/TestBoundedMultipleInputOperator.java | 17 +-
...eyedProcessOperatorWithWatermarkDelayTest.scala | 2 +-
.../streaming/runtime/MultipleInputITCase.java | 120 +++++-
26 files changed, 1064 insertions(+), 418 deletions(-)
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractInput.java
copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/{MultipleInputTransformation.java => AbstractMultipleInputTransformation.java} (87%)
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/KeyedMultipleInputTransformation.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2Test.java