Posted by
Maminspapin on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Parallelism-with-onTimer-in-connectedStream-tp43996p43997.html
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/