[hotfix][runtime] Remove useless imports and incorrect comment of Str…

…eamingJobGraphGeneratorTest
changzhiwin · Jan 29, 2023 · 640fbb8 · 640fbb8
1 parent a55ae1c
commit 640fbb8
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...va/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java b/...va/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
@@ -143,7 +143,6 @@
 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 @@ void testSinkSupportConcurrentExecutionAttempts() {
         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");