Skip to content

Commit 3d89669

Browse files
author
huyuanfeng
committed
fix comment
1 parent fb7da34 commit 3d89669

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -404,7 +404,7 @@ protected static <KEY, Context extends JobAutoScalerContext<KEY>> int scale(
404404
newParallelism = Math.min(Math.max(parallelismLowerLimit, newParallelism), upperBound);
405405

406406
var adjustByMaxParallelismOrPartitions =
407-
inputShipStrategies.isEmpty() || inputShipStrategies.contains(HASH);
407+
numSourcePartitions > 0 || inputShipStrategies.contains(HASH);
408408
if (!adjustByMaxParallelismOrPartitions) {
409409
return newParallelism;
410410
}

0 commit comments

Comments
 (0)