Re: 请教设置了table.exec.state.ttl后,结果数据不更新问题

2022-02-14 文章 Caizhi Weng
Hi! 图片不能显示,建议传到 imgur 等外部图床上,再把链接贴到邮件里。 设置 state ttl 之前 sink 数据能一直更新吗?确认不是因为后来的数据不符合某些 where 条件导致的吗? liangjinghong 于2022年2月12日周六 14:39写道: > 你好,我是一个flink新手。为了进行状态管理,我在代码中设置了configuration.setString("table.exec.state.ttl","12h"); > > 然而,在flink作业运行12小时后,*我的update结果表再也没有更新过*。从web

请教设置了table.exec.state.ttl后,结果数据不更新问题

2022-02-11 文章 liangjinghong
你好,我是一个flink新手。为了进行状态管理,我在代码中设置了configuration.setString("table.exec.state.ttl","12h"); 然而,在flink作业运行12小时后,我的update结果表再也没有更新过。从web ui可以看到,我的源头与一些算子的Records Sent一直在增长,任务也没有出现任何异常,checkpoint也正常,所以我很苦恼是哪里出现了问题 [cid:image005.jpg@01D8201E.4C9301C0] [cid:image006.jpg@01D8201E.4C9301C0] 以下是我的SQL语句: