Update flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tun…

…ing/MemoryTuning.java Co-authored-by: Maximilian Michels <[email protected]>
1996fanrui · Feb 23, 2024 · dec73d7 · dec73d7
1 parent 5600e32
commit dec73d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java b/flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java
@@ -299,7 +299,7 @@ private static MemorySize adjustNetworkMemory(
     @VisibleForTesting
     static int calculateNetworkSegmentNumber(
             int currentVertexParallelism,
-            int otherVertexParallelism,
+            int connectedVertexParallelism,
             String shipStrategy,
             int buffersPerChannel,
             int floatingBuffers) {