Skip to content

Commit 2f01999

Browse files
author
huyuanfeng
committed
[hotfix] Fix incorrect messageKey passed in ScalingLimited event
1 parent 670bfcf commit 2f01999

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
@@ -456,7 +456,7 @@ protected static <KEY, Context extends JobAutoScalerContext<KEY>> int scale(
456456
AutoScalerEventHandler.Type.Warning,
457457
SCALING_LIMITED,
458458
message,
459-
SCALING_LIMITED + vertex + (scaleFactor * currentParallelism),
459+
SCALING_LIMITED + vertex + newParallelism,
460460
context.getConfiguration().get(SCALING_EVENT_INTERVAL));
461461
return p;
462462
}

0 commit comments

Comments
 (0)