You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2023/02/09 03:46:30 UTC
[flink] 01/03: [hotfix] fix not incorrect comment in testIntermediateDataSetReuse.
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 14b9f793f41c43857c554254a6cf254a234019a1
Author: Weijie Guo <re...@163.com>
AuthorDate: Mon Feb 6 12:21:33 2023 +0800
[hotfix] fix not incorrect comment in testIntermediateDataSetReuse.
---
.../flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
index 6018c380ea3..b2448fd103b 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
@@ -1799,7 +1799,8 @@ class StreamingJobGraphGeneratorTest {
// this can not reuse the same intermediate dataset because of different partitioner
source.broadcast().addSink(new DiscardingSink<>()).setParallelism(2);
- // these two vertices can reuse the same intermediate dataset because of the pipelined edge
+ // these two vertices can not reuse the same intermediate dataset because of the pipelined
+ // edge
source.forward().addSink(new DiscardingSink<>()).setParallelism(1).disableChaining();
source.forward().addSink(new DiscardingSink<>()).setParallelism(1).disableChaining();