退订
--
发自我的网易邮箱手机智能版
非常感谢您的答复。接下来按照您提供的思路进行排查
在 2019-05-15 16:23:04，"Terry Wang" 写道：
>有可能是并行度设置大时，source的部分并发没有数据，导致eventTime未更新。可以排查下是否是这个问题
>
>> 在 2019年5月15日，下午2:18，13341000780 <13341000...@163.com> 写道：
>>
>> hi, 各位大牛好！
>> 自定义了窗口触发器trigger，在onElement函数中注册了EventTimeTimer。出现了很离奇的问题，当并行度Parallelism
>>
hi, 各位大牛好！
自定义了窗口触发器trigger，在onElement函数中注册了EventTimeTimer。出现了很离奇的问题，当并行度Parallelism
设置的比slots数和CPU核数小时，能成功触发onEventTime函数，当大于slots数或者大于CPU核数时，发现无法触发onEventTime，已确定元素能成功进入窗口，即onElement函数能成功触发。有人遇到过类似的问题吗，求解答。
非常感谢.
hi, 各位大牛好！
kafka作为数据源时，在 Properties
中设置了group.id，信息，但是同一个group下的consumer中能消费到同一个主题下想同一条消息。 另外我单独使用 kafka
consumer时就不会出现这种情况，即同一个消费组下只能有一个 consume 消费到同一条消息。
各位大牛有人遇到过这个问题吗？望赐教。
非常感谢.
