This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 640fbb8936650415b207a76408ca97f0c922eb38 Author: ifndef-SleePy <[email protected]> AuthorDate: Sun Jan 29 01:36:29 2023 +0800 [hotfix][runtime] Remove useless imports and incorrect comment of StreamingJobGraphGeneratorTest --- .../flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java | 2 -- 1 file changed, 2 deletions(-) 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 a46b200b31d..0046d9055a5 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 @@ -143,7 +143,6 @@ import static org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.ar import static org.apache.flink.util.Preconditions.checkNotNull; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatThrownBy; -import static org.assertj.core.api.InstanceOfAssertFactories.stream; /** Tests for {@link StreamingJobGraphGenerator}. */ @ExtendWith(TestLoggerExtension.class) @@ -1803,7 +1802,6 @@ class StreamingJobGraphGeneratorTest { env.setRuntimeMode(RuntimeExecutionMode.BATCH); final DataStream<Integer> source = env.fromElements(1, 2, 3).name("source"); - // source -> (map1 -> map2) -> sink source.rebalance() .sinkTo(new TestSinkWithSupportsConcurrentExecutionAttempts()) .name("sink");
