Re: CoProcessFunction processElement1 and processElement2

Hi Min, all methods in your user-defined function are always run in the same thread - they cannot occur simultaneously. That includes all functions related to state management (snapshotState, initializeState), life-cycle (open, close), and timers. To support multiple slots per machine, Flink main

Re: CoProcessFunction processElement1 and processElement2

They are designed to avoid race condition. Get Outlook for Android From: Tan, Min Sent: Sunday, November 1, 2020 2:15:54 AM To: user Subject: CoProcessFunction processElement1 and processElement2 Hi, Can someone confirm that the proce