flink-kafka Trigger 无法触发问题

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

Re: 请教集群稳定性问题

解决了我的问题，非常感谢 liu_mingzhang 于2019年5月13日周一 上午9:48写道： > > > 你好,这个问题需要把javax.ws.rs-api-2.0.jar 对应版本的包放到$FLINK_HOME/lib下 > 在2019年5月12日 11:05，naisili Yuan 写道： > 好的，谢谢回复。 > 想问下，生产环境适合用standalone > cluster模式部署嘛，我感觉集群还是不稳定，10个job跑不了24小时就出问题，基本都是心跳丢失或者slot 被移除之类的问题。 > 但是我部署flink on yarn又出了问题，自己解决半天也出了问题，希

Re: Flink 与 Hive 集成问题

@Bowen Li 多谢解答。 社区的代码我有留意，也注意到上面的新模块。 我们目前是1.7.1。想了解下目前是否可能做个简单版本，看是否有思路。 图片apache邮箱列表是不支持的，你提到的钉钉是 “Apache Flink China社区大群” 这个群吗，我加了。 thx. On Wed, May 15, 2019 at 7:35 AM Bowen Li wrote: > Hi, > > 我们正在做 Flink-Hive 平台级的元数据和数据的集成，你可以关注下： flink-connector-hive >

Re: Flink 与 Hive 集成问题

Hi, 我们正在做 Flink-Hive 平台级的元数据和数据的集成，你可以关注下： flink-connector-hive module， Hive元数据 FLINK-11479 ，Hive数据 FLINK-10729

订阅邮件

FYI | | hao飞飞 | | hao123...@126.com | 签名由网易邮箱大师定制