Skip to content

Commit

Permalink
[FLINK-14612][runtime] Change Type of Field intermediateResults from …
Browse files Browse the repository at this point in the history
…ConcurrentHashMap to HashMap

This closes apache#10102.
  • Loading branch information
yanghua authored and GJL committed Nov 12, 2019
1 parent 0022d4a commit a8e3a20
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -199,7 +199,7 @@ public class ExecutionGraph implements AccessExecutionGraph {
private final List<ExecutionJobVertex> verticesInCreationOrder;

/** All intermediate results that are part of this graph. */
private final ConcurrentHashMap<IntermediateDataSetID, IntermediateResult> intermediateResults;
private final Map<IntermediateDataSetID, IntermediateResult> intermediateResults;

/** The currently executed tasks, for callbacks. */
private final ConcurrentHashMap<ExecutionAttemptID, Execution> currentExecutions;
Expand Down Expand Up @@ -463,7 +463,7 @@ public ExecutionGraph(
this.userClassLoader = Preconditions.checkNotNull(userClassLoader, "userClassLoader");

this.tasks = new ConcurrentHashMap<>(16);
this.intermediateResults = new ConcurrentHashMap<>(16);
this.intermediateResults = new HashMap<>(16);
this.verticesInCreationOrder = new ArrayList<>(16);
this.currentExecutions = new ConcurrentHashMap<>(16);

Expand Down

0 comments on commit a8e3a20

Please sign in to comment.