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 2019/08/19 14:33:29 UTC
[flink] branch master updated (24ab7bb -> 2f324f8)
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 24ab7bb [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries
add e9c9b0e [FLINK-11879][runtime] Add getStreamOperatorClass() to the StreamOperatorFactory interface
add 9042a15 [hotfix][test] Separate some shared inner classes from test classes into the separate files
add 2f324f8 [FLINK-11879][runtime] Add validators for the uses of InputSelectable
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/api/graph/StreamGraph.java | 14 +---
.../api/graph/StreamingJobGraphGenerator.java | 31 +++++++++
.../api/operators/SimpleOperatorFactory.java | 7 +-
.../api/operators/StreamOperatorFactory.java | 7 +-
.../streaming/runtime/tasks/OperatorChain.java | 10 +++
.../flink/streaming/runtime/tasks/StreamTask.java | 17 +++++
.../api/graph/StreamingJobGraphGeneratorTest.java | 19 ++++++
.../tasks/StreamTaskSelectiveReadingTest.java | 75 ++--------------------
.../streaming/runtime/tasks/StreamTaskTest.java | 37 +++++++++++
.../runtime/tasks/TwoInputStreamTaskTest.java | 34 +---------
.../TestAnyModeReadingStreamOperator.java} | 34 ++++++----
.../TestBoundedTwoInputOperator.java} | 29 +++++----
.../util/TestSequentialReadingStreamOperator.java | 66 +++++++++++++++++++
.../table/runtime/generated/GeneratedClass.java | 6 +-
.../runtime/operators/CodeGenOperatorFactory.java | 9 ++-
.../generated/GeneratedCollectorWrapper.java | 2 +-
.../generated/GeneratedFunctionWrapper.java | 2 +-
.../generated/GeneratedResultFutureWrapper.java | 2 +-
.../runtime/StreamTaskSelectiveReadingITCase.java | 4 +-
19 files changed, 254 insertions(+), 151 deletions(-)
copy flink-streaming-java/src/test/java/org/apache/flink/streaming/{runtime/tasks/TestBoundedOneInputStreamOperator.java => util/TestAnyModeReadingStreamOperator.java} (52%)
copy flink-streaming-java/src/test/java/org/apache/flink/streaming/{runtime/tasks/TestBoundedOneInputStreamOperator.java => util/TestBoundedTwoInputOperator.java} (53%)
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/util/TestSequentialReadingStreamOperator.java