[GitHub] [flink-ml] zhipeng93 opened a new pull request #34: [FLINK-24279] [hotfix]: fix nullpointer exception when broadcast variables are cleaned

Sun, 14 Nov 2021 20:56:23 -0800 


zhipeng93 opened a new pull request #34:
URL: https://github.com/apache/flink-ml/pull/34


   This PR fixes the concurrency bug in the following case:
   
   Step1: BroadcastVariableReceiverOperator#endInput
   Step2: BroadcastVariableReceiverOperator#initializeState
   Step3: AbstractBroadcastWrapperOperator#close
   Step4: BroadcastVariableReceiverOperator#snapshot
   
   In Step4, we assumed that the broadcastVariable is still stored in 
`BroadcastContext`. However, it may have been removed by 
`AbstractBroadcastWrapperOperator` in Step3.
   
   
   fix nullpointer exception when BroadcastWrapp……erOperator cleans the 
broadcast variable


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to