Re: flink sql cdc做计算后, elastic search connector 多并发sink 会有问题,偶现!数据量较大,目前还没较好复现。请问有人是否也遇到过类似的问题。

2021-06-16 Thread mokaful
相同问题,请问有处理方式吗 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Flink CEP事件查询,如何在flink运行中动态更新cep规则

2021-04-15 Thread mokaful
broadcast stream读取zk配置 + groovy动态编译生成pattern -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink作业版本管理实现方案探讨

2021-01-19 Thread mokaful
是的,参照了flink自带的作业提交流程思路,加入了定制逻辑 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink作业版本管理实现方案探讨

2021-01-19 Thread mokaful
观望~~我们目前的实现是采用数据库,数据库+一个专门提交作业的gateway程序 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Flink CEP 动态加载 pattern

2021-01-17 Thread mokaful
Hi,对于动态更新cep pattern这个问题,不知道楼主现在有啥突破可以借鉴一下呢? -- Sent from: http://apache-flink.147419.n8.nabble.com/