You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by wa...@apache.org on 2023/02/16 15:15:07 UTC
[flink] 01/03: [hotfix] Fix the missing parameter error in ForwardForConsecutiveHashPartitionerTest
This is an automated email from the ASF dual-hosted git repository.
wanglijie pushed a commit to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 35876807595a3bbc5711863bd746c5190b1e16ed
Author: Lijie Wang <wa...@gmail.com>
AuthorDate: Tue Feb 14 21:32:51 2023 +0800
[hotfix] Fix the missing parameter error in ForwardForConsecutiveHashPartitionerTest
---
.../partitioner/ForwardForConsecutiveHashPartitionerTest.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitionerTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitionerTest.java
index c33adbd92a8..57e7b6238e5 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitionerTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitionerTest.java
@@ -23,7 +23,6 @@ import org.apache.flink.streaming.api.graph.NonChainedOutput;
import org.apache.flink.streaming.api.graph.StreamConfig;
import org.apache.flink.streaming.api.graph.StreamEdge;
import org.apache.flink.streaming.api.transformations.StreamExchangeMode;
-import org.apache.flink.util.TestLogger;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
@@ -31,7 +30,7 @@ import org.junit.jupiter.api.Test;
import java.util.List;
/** Test for {@link ForwardForConsecutiveHashPartitioner}. */
-class ForwardForConsecutiveHashPartitionerTest extends TestLogger {
+class ForwardForConsecutiveHashPartitionerTest {
@Test
void testConvertToForwardPartitioner() {
@@ -46,7 +45,8 @@ class ForwardForConsecutiveHashPartitionerTest extends TestLogger {
"group1",
"group1",
new ForwardForConsecutiveHashPartitioner<>(
- new KeyGroupStreamPartitioner<>(record -> 0L, 100)));
+ new KeyGroupStreamPartitioner<>(record -> 0L, 100)),
+ streamExchangeMode);
List<JobVertex> jobVertices = jobGraph.getVerticesSortedTopologicallyFromSources();
Assertions.assertThat(jobVertices.size()).isEqualTo(1);
JobVertex vertex = jobGraph.getVerticesSortedTopologicallyFromSources().get(0);
@@ -69,7 +69,8 @@ class ForwardForConsecutiveHashPartitionerTest extends TestLogger {
"group1",
"group2",
new ForwardForConsecutiveHashPartitioner<>(
- new KeyGroupStreamPartitioner<>(record -> 0L, 100)));
+ new KeyGroupStreamPartitioner<>(record -> 0L, 100)),
+ streamExchangeMode);
List<JobVertex> jobVertices = jobGraph.getVerticesSortedTopologicallyFromSources();
Assertions.assertThat(jobVertices.size()).isEqualTo(2);
JobVertex sourceVertex = jobGraph.getVerticesSortedTopologicallyFromSources().get(0);