diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/partitionrelease/RegionPartitionGroupReleaseStrategy.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/partitionrelease/RegionPartitionGroupReleaseStrategy.java index 2233f7ffbed95..4b529c9eabdd1 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/partitionrelease/RegionPartitionGroupReleaseStrategy.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/partitionrelease/RegionPartitionGroupReleaseStrategy.java @@ -70,8 +70,8 @@ private void initRegionExecutionViewByVertex( for (SchedulingPipelinedRegion pipelinedRegion : newRegions) { final PipelinedRegionExecutionView regionExecutionView = new PipelinedRegionExecutionView(pipelinedRegion); - for (SchedulingExecutionVertex executionVertexId : pipelinedRegion.getVertices()) { - regionExecutionViewByVertex.put(executionVertexId.getId(), regionExecutionView); + for (SchedulingExecutionVertex executionVertex : pipelinedRegion.getVertices()) { + regionExecutionViewByVertex.put(executionVertex.getId(), regionExecutionView); } } }