[flink] 01/10: [hotfix][coordination] Add Main-Thread check to OperatorEvent sending on Execution.

[sewen]

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 11717ced989ace3b46582a68e059fb63c8113c94
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Apr 14 15:38:49 2021 +0200

    [hotfix][coordination] Add Main-Thread check to OperatorEvent sending on 
Execution.
    
    Now that the threading model of the OperatorCoordinatorHolder has been 
adjusted, we can
    finally have this check and use this method in accordance with the general 
contract of
    the Scheduler.
---
 .../main/java/org/apache/flink/runtime/executiongraph/Execution.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
index a39000a..c336d23 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -854,6 +854,8 @@ public class Execution
      */
     public CompletableFuture<Acknowledge> sendOperatorEvent(
             OperatorID operatorId, SerializedValue<OperatorEvent> event) {
+
+        assertRunningInJobMasterMainThread();
         final LogicalSlot slot = assignedResource;
 
         if (slot != null && (getState() == RUNNING || getState() == 
INITIALIZING)) {