Skip to content

Commit f65a33a

Browse files
author
huyuanfeng
committed
[hotfix] Fix incorrect messageKey passed in ScalingLimited event
1 parent 5d29554 commit f65a33a

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
@@ -464,7 +464,7 @@ protected static <KEY, Context extends JobAutoScalerContext<KEY>> int scale(
464464
AutoScalerEventHandler.Type.Warning,
465465
SCALING_LIMITED,
466466
message,
467-
SCALING_LIMITED + vertex + (scaleFactor * currentParallelism),
467+
SCALING_LIMITED + vertex + newParallelism,
468468
context.getConfiguration().get(SCALING_EVENT_INTERVAL));
469469
return p;
470470
}

0 commit comments

Comments
 (0)