You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2022/09/14 14:54:11 UTC
[flink] 02/05: [hotfix] Let scheduledRegions using the set backed up by IdentityHashMap
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 77eab72fb011a8684fe4c8e95307decf13c2881a
Author: Weijie Guo <re...@163.com>
AuthorDate: Fri Sep 2 17:59:49 2022 +0800
[hotfix] Let scheduledRegions using the set backed up by IdentityHashMap
---
.../runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java
index 134f1eda5d3..1b4bf431648 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java
@@ -61,7 +61,8 @@ public class PipelinedRegionSchedulingStrategy implements SchedulingStrategy {
private final Set<ConsumedPartitionGroup> crossRegionConsumedPartitionGroups =
Collections.newSetFromMap(new IdentityHashMap<>());
- private final Set<SchedulingPipelinedRegion> scheduledRegions = new HashSet<>();
+ private final Set<SchedulingPipelinedRegion> scheduledRegions =
+ Collections.newSetFromMap(new IdentityHashMap<>());
public PipelinedRegionSchedulingStrategy(
final SchedulerOperations schedulerOperations,