使用了流应用中使用了mysql jdbc的source，Execution处于FINISHED状态无法生成检查点

Thu, 21 Jan 2021 01:52:29 -0800 

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，这种有其它办法吗？


感谢大佬指导一下，拜谢！
| |
刘海
|
|
liuha...@163.com
|
签名由网易邮箱大师定制

回复