You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 13341000780 <13...@163.com> on 2019/05/15 06:18:23 UTC

flink-kafka Trigger 无法触发问题

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


非常感谢.

Re:Re: flink-kafka Trigger 无法触发问题

Posted by 13341000780 <13...@163.com>.
非常感谢您的答复。接下来按照您提供的思路进行排查








在 2019-05-15 16:23:04，"Terry Wang" <zj...@gmail.com> 写道：
>有可能是并行度设置大时，source的部分并发没有数据，导致eventTime未更新。可以排查下是否是这个问题
>
>> 在 2019年5月15日，下午2:18，13341000780 <13...@163.com> 写道：
>> 
>> hi, 各位大牛好！
>>   自定义了窗口触发器trigger，在onElement函数中注册了EventTimeTimer。出现了很离奇的问题，当并行度Parallelism 设置的比slots数和CPU核数小时，能成功触发onEventTime函数，当大于slots数或者大于CPU核数时，发现无法触发onEventTime，已确定元素能成功进入窗口，即onElement函数能成功触发。有人遇到过类似的问题吗，求解答。
>> 
>> 
>> 非常感谢.
>> 
>> 
>> 
>> 
>> 
>

Re: flink-kafka Trigger 无法触发问题

Posted by Terry Wang <zj...@gmail.com>.
有可能是并行度设置大时，source的部分并发没有数据，导致eventTime未更新。可以排查下是否是这个问题

> 在 2019年5月15日，下午2:18，13341000780 <13...@163.com> 写道：
> 
> hi, 各位大牛好！
>   自定义了窗口触发器trigger，在onElement函数中注册了EventTimeTimer。出现了很离奇的问题，当并行度Parallelism 设置的比slots数和CPU核数小时，能成功触发onEventTime函数，当大于slots数或者大于CPU核数时，发现无法触发onEventTime，已确定元素能成功进入窗口，即onElement函数能成功触发。有人遇到过类似的问题吗，求解答。
> 
> 
> 非常感谢.
> 
> 
> 
> 
>