Hongshun Wang created FLINK-36076:
-------------------------------------

             Summary: Hotfix: Set isSchemaChangeApplying as 
isSchemaChangeApplying for thread safe.
                 Key: FLINK-36076
                 URL: https://issues.apache.org/jira/browse/FLINK-36076
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
    Affects Versions: cdc-3.2.0
            Reporter: Hongshun Wang
             Fix For: cdc-3.3.0


Current, we apply schema change asynchronous.  
SchemaChangeThreadPool will set isSchemaChangeApplying as true when apply 
schema change event. And the main thread which handle operater event will check 
isSchemaChangeApplying.
 
For thread safe, this should be volatile.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to