HI! 这边做测试时遇到一个问题: 在流应用中使用了一个mysql jdbc的source作为维表,为了优化处理效率使用了Lookup Cache,下面是注册的表: bsTableEnv.executeSql("CREATE TABLE tm_dealers (dealer_code STRING,is_valid DECIMAL(10,0),proctime AS PROCTIME(),PRIMARY KEY (dealer_code) NOT ENFORCED\n" + ") WITH (" + "'connector' = 'jdbc'," + "'url' = 'jdbc:mysql://10.0.15.83:3306/flink-test?useSSL=false'," + "'table-name' = 'tm_dealers'," + "'driver' = 'com.mysql.cj.jdbc.Driver'," + "'username' = 'root'," + "'password' = 'Cdh2020:1'," + "'lookup.cache.max-rows' = '500',"+ "'lookup.cache.ttl' = '1800s',"+ "'sink.buffer-flush.interval' = '60s'"+ ")");
我发现这样的话checkpoint配置会失效,不能触发检查点,日志报如下错误: job bad9f419433f78d24e703e659b169917 is notin state RUNNING but FINISHED instead. Aborting checkpoint.
进入WEB UI 看一下视图发现该Execution处于FINISHED状态,FINISHED状态无法进行checkpoint,这种有其它办法吗?
感谢大佬指导一下,拜谢!*来自志愿者整理的flink
你好,你需要使用 Temporal Table Join 的语法,具体操作可以参考官网 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/joins.html*来自志愿者整理的flink
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。