Flink upgraded to version 1.12.0 and started from SavePoint to report an error

2021-05-16 文章 王炳焱
When I upgraded from Flink1.10.0 to Flink1.12.0. Unable to restore SavePoint And prompt the following error 2021-05-14 22:02:44,716 WARN org.apache.flink.metrics.MetricGroup [] - The operator name Calc(select=[((CAST((log_info get_json_object2 _UTF-16LE'eventTime')

Re: FlinKCEP

2021-05-16 文章 tonychen
在FLINK-SQL下用eventtime和proctime都可以进行CEP计算 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: pyflink双流join

2021-05-16 文章 qianhuan
非常感谢🙏 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: pyflink双流join

2021-05-16 文章 Dian Fu
用Table API的话，可以看一下这个： https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/tableapi/#joins 另外，也可以直接在PyFlink中调用SQL语句： https://ci.apache.org/projects/flink/flink-docs-release-1.13/d

pyflink双流join

2021-05-16 文章 qianhuan
想实现pyflink双流join，没有找到相关示例，有没有大神指导下用pyflink是否能实现？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 关于union之后的keyBy问题

2021-05-16 文章 HunterXHunter
这部分没人报bug，所以社区一般是不会去验证的。所以你要给出你的代码，同时对问题描述尽量清晰，否则很难有人去自己写代码验证问题。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

????union??????keyBy????

2021-05-16 文章 ????????????
Hi,All     ??:??flink??union/joinkeybytimewindow??keybykey??     ~

ExtractionUtils#getClassReader 触发open too many files 异常

2021-05-16 文章 zhiping.lin
你好，对于org.apache.flink.table.types.extraction.ExtractionUtils的getClassReader方法我有个疑问，为何在打开inputStream后没有进行及时关闭？ 源码如下： private static ClassReader getClassReader(Class cls) { final String className = cls.getName().replaceFirst("^.*\\.", "") + ".class"; try { return new

Exception: Could not perform checkpoint

2021-05-16 文章 gen
Hi, all: 我的一个任务 稳定运行了一段时间后， 出现异常 导致不断重启。 版本 Flink 1.10， 请问下 从这个异常上看是业务的问题么，还是flink问题？ flink ui上日志为: 2021-05-14 16:12:30 java.lang.Exception: Could not perform checkpoint 6713 for operator Source: kafka topic[mt_elk_log] source -> Flat Map -> Sink: customerAccessLogIndex sink (2/4). at