flink-kafka Trigger 无法触发问题

Tue, 14 May 2019 23:19:27 -0700 

hi, 各位大牛好！
   自定义了窗口触发器trigger，在onElement函数中注册了EventTimeTimer。出现了很离奇的问题，当并行度Parallelism 
设置的比slots数和CPU核数小时，能成功触发onEventTime函数，当大于slots数或者大于CPU核数时，发现无法触发onEventTime，已确定元素能成功进入窗口，即onElement函数能成功触发。有人遇到过类似的问题吗，求解答。


非常感谢.

回复