开发者社区> 问答> 正文

使用了流应用中使用了mysql jdbc的source,Execution处于FINISHED有问题

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

展开
收起
毛毛虫雨 2021-12-05 22:13:52 754 0
1 条回答
写回答
取消 提交回答
  • 你好,你需要使用 Temporal Table Join 的语法,具体操作可以参考官网 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/joins.html*来自志愿者整理的flink

    2021-12-05 23:42:38
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像