Skip to content

Commit

Permalink
[FLINK-14602][runtime] Change Type of Field tasks from ConcurrentHash…
Browse files Browse the repository at this point in the history
…Map to HashMap

This closes apache#10101.
  • Loading branch information
yanghua authored and GJL committed Nov 12, 2019
1 parent a8e3a20 commit 512b4f7
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -193,7 +193,7 @@ public class ExecutionGraph implements AccessExecutionGraph {
private boolean isStoppable = true;

/** All job vertices that are part of this graph. */
private final ConcurrentHashMap<JobVertexID, ExecutionJobVertex> tasks;
private final Map<JobVertexID, ExecutionJobVertex> tasks;

/** All vertices, in the order in which they were created. **/
private final List<ExecutionJobVertex> verticesInCreationOrder;
Expand Down Expand Up @@ -462,7 +462,7 @@ public ExecutionGraph(
allocationTimeout);
this.userClassLoader = Preconditions.checkNotNull(userClassLoader, "userClassLoader");

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

0 comments on commit 512b4f7

Please sign in to comment.