Some logs and comments: --- user key: Test_1 __Co-Keyed-Process -> Sink: Sink (2/3)#0 // get user and store in 2 thread (process1: user stream) --- user key: Test_2 __Co-Keyed-Process -> Sink: Sink (3/3)#0 // get user and store in 3 thread (process1: user stream) --- user key: Test_3 __Co-Keyed-Process -> Sink: Sink (1/3)#0 // get user and store in 1 thread (process1: user stream)
+++ event key: Test_1 __Co-Keyed-Process -> Sink: Sink (2/3)#0 // get event and store in 2 thread (process2: event stream) !!! Reg_ontimer: 2021-05-27T10:07:16.000+03:00 user: Test_1, event: Test_1__Co-Keyed-Process -> Sink: Sink (2/3)#0 // reg the work in ontimer 2 thread (process2: event stream) +++ event key: Test_2 __Co-Keyed-Process -> Sink: Sink (3/3)#0 // get event and store in 3 thread (process2: event stream) !!! Reg_ontimer: 2021-05-27T10:07:17.000+03:00 user: Test_2, event: Test_2 __Co-Keyed-Process -> Sink: Sink (3/3)#0 // reg the work in ontimer in 3 thread (process2: event stream) +++ event key: Test_3__Co-Keyed-Process -> Sink: Sink (1/3)#0 // get event and store in 1 thread (process2: event stream) !!! Reg_ontimer: 2021-05-27T10:07:17.000+03:00 user: Test_3, event: Test_3 __Co-Keyed-Process -> Sink: Sink (1/3)#0 // reg the work in ontimer in 1 thread (process2: event stream) Reg_onTimer() next push: 2021-05-27T10:07:26.000+03:00 action: reg first push, user: Test_1 __Co-Keyed-Process -> Sink: Sink (2/3)#0 // ontimer 2 thread Reg_onTimer() next push: 2021-05-27T10:07:27.000+03:00 action: reg first push, user: Test_2 __Co-Keyed-Process -> Sink: Sink (3/3)#0 // ontimer 3 thread Reg_onTimer() next push: 2021-05-27T10:07:27.000+03:00 action: reg first push, user: Test_3 __Co-Keyed-Process -> Sink: Sink (1/3)#0 // ontimer 1 thread ---> THE SAME TIME for Test_2 and Test_3 !!! 2021-05-27T10:07:26.016+03:00 ###### action: first push, user: Test_1 __Co-Keyed-Process -> Sink: Sink (2/3)#0 // ontimer 2 thread 2021-05-27T10:07:27.005+03:00 ###### action: first push, user: Test_3 __Co-Keyed-Process -> Sink: Sink (1/3)#0 // ontimer 1 thread 2021-05-27T10:07:27.008+03:00 ###### action: first push, user: Test_3 __Co-Keyed-Process -> Sink: Sink (3/3)#0 // ontimer 3 thread ---> No action for Test_2, twice action for Test_3 -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
