[flink] 04/05: PR comment

[gy...@apache.org]

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

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

commit 41518d6b5e03eeb7b30b0e60c89f4dcdfdcb814c
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Thu Dec 15 17:30:07 2022 +0100

    PR comment
    
    Co-authored-by: Rui Fan <19...@gmail.com>
---
 .../java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
index ff398d37d1c..35261d449f2 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
@@ -1858,7 +1858,7 @@ public class StreamTaskTest extends TestLogger {
             recordWriterDelegate =
                     harness.streamTask.createRecordWriterDelegate(
                             harness.streamTask.configuration, harness.streamMockEnvironment);
-            // We should now have a RescalePartitioner to distribute the load
+            // We should now have a RebalancePartitioner to distribute the load
             // for the non-matching downstream parallelism
             assertTrue(
                     ((ChannelSelectorRecordWriter)