我在社区建了个issue:https://issues.apache.org/jira/browse/FLINK-16534 后续你可以关注下
Best, Kurt On Wed, Mar 11, 2020 at 12:54 PM Kurt Young <[email protected]> wrote: > sql client 目前还不支持这个功能。 > > Best, > Kurt > > > On Wed, Mar 11, 2020 at 11:35 AM [email protected] < > [email protected]> wrote: > >> Hi Kurt, >> 确实是可以 直接 flink cancel -s 保存状态。 >> 但我是用 flink-sql-client 直接写 sql 提交的 job,再提交的时候怎样可以指定状态目录让这个任务从状态恢复呢? >> >> 谢谢, >> 王磊 >> >> >> *Sender:* Kurt Young <[email protected]> >> *Send Time:* 2020-03-11 10:38 >> *Receiver:* user-zh <[email protected]> >> *Subject:* Re: flink sql join 可以有 state 存储并从 state 恢复数据吗? >> 理论上来说,flink SQL的作业在编译完生成JobGraph并提交到集群上后,和Datastream的作业就没有什么本质的不同了。 >> 应该也可以支持flink cancel -s 的功能,你可以先试下,如果碰到什么问题再看看。 >> >> Best, >> Kurt >> >> >> On Wed, Mar 11, 2020 at 10:24 AM [email protected] < >> [email protected]> wrote: >> >> > 有两个表: >> > tableA: key valueA >> > tableB: key valueB >> > >> > 我之前用 flink state 的方式存储 tableA,tableB 的消息过来以后去 query 这个 state 得到 valueA >> > 直接 写 flinkSQL 也可以实现这种功能,但这两个表有时间差,任务停止后重新提交会丢失部分 join 的结果。 >> > flinkSQL 有没有类似 flink cancel -s 保存 state 的功能呢? >> > >> > 谢谢, >> > 王磊 >> > >> >>
