[FLINK-12036] Simplify ExecutionGraph by removing legacy concurrency code

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Done
• Affects Version/s: 1.8.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Till Rohrmann
• Created: 27/Mar/19 13:39
• Updated: 23/Oct/20 13:13
• Resolved: 23/Oct/20 13:13

Description

With FLINK-11417, we made the ExecutionGraph single threaded. Consequently all the logic which handles concurrent state changes is no longer needed (e.g. AtomicReferenceFieldUpdater, checking for concurrent changes, etc.). This issue is the umbrella to collect every legacy concurrency code which can be removed from the ExecutionGraph.

Issue Links

• is related to: FLINK-11417 Make access to ExecutionGraph single threaded from JobMaster main thread

Sub-Tasks

• Remove ASSIGNED_SLOT_UPDATER in Execution.tryAssignResource: Closed
• Remove STATE_UPDATER in ExecutionGraph: Closed
• Remove GLOBAL_VERSION_UPDATER in ExecutionGraph: Closed
• Remove progressLock in ExecutionGraph: Closed
• Remove progressLock from ExecutionGraph: Closed
• Change Type of Field verticesFinished from AtomicInteger to int: Closed
• Change Type of Field tasks from ConcurrentHashMap to HashMap: Closed
• Change Type of Field intermediateResults from ConcurrentHashMap to HashMap: Closed
• Change Type of Field currentExecutions from ConcurrentHashMap to HashMap: Closed
• Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList: Closed
• Remove STATE_UPDATER in Execution: Closed
• Remove volatile variable in ExecutionVertex: Closed