Skip to content

Commit

Permalink
[FLINK-14655][runtime] Change type of field jobStatusListeners from C…
Browse files Browse the repository at this point in the history
…opyOnWriteArrayList to ArrayList

This closes apache#10116.
  • Loading branch information
yanghua authored and GJL committed Jan 6, 2020
1 parent a50d9ff commit a5ef143
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,6 @@
import java.util.Optional;
import java.util.concurrent.CancellationException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
Expand Down Expand Up @@ -357,7 +356,7 @@ public ExecutionGraph(
this.verticesInCreationOrder = new ArrayList<>(16);
this.currentExecutions = new HashMap<>(16);

this.jobStatusListeners = new CopyOnWriteArrayList<>();
this.jobStatusListeners = new ArrayList<>();

this.stateTimestamps = new long[JobStatus.values().length];
this.stateTimestamps[JobStatus.CREATED.ordinal()] = System.currentTimeMillis();
Expand Down

0 comments on commit a5ef143

Please sign in to comment.