You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by zh...@apache.org on 2022/06/24 12:02:59 UTC

[flink] branch master updated (c66101d5186 -> cef491eab34)

This is an automated email from the ASF dual-hosted git repository.

zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from c66101d5186 [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions
     add cef491eab34 [FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink operators

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/runtime/jobgraph/JobVertex.java   |  22 +++
 .../flink/streaming/api/graph/StreamGraph.java     |  16 ++
 .../api/graph/StreamingJobGraphGenerator.java      |  23 +++
 .../translators/SinkTransformationTranslator.java  |   6 +-
 .../StreamingJobGraphGeneratorSourceSinkTest.java  | 162 +++++++++++++++++++++
 .../api/graph/StreamingJobGraphGeneratorTest.java  |   2 +-
 6 files changed, 229 insertions(+), 2 deletions(-)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorSourceSinkTest.java