Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 wangl...@geekplus.com.cn
我试了下,是可以的。 Thanks wangl...@geekplus.com.cn Sender: Kurt Young Send Time: 2020-03-11 19:59 Receiver: wangl...@geekplus.com.cn cc: user-zh Subject: Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗? 那有可能是可以的,你可以试试看 Best, Kurt On Wed, Mar 11, 2020 at 6:57 PM wangl...@geekplus.com.cn wrote

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 zhisheng
之前已经存在的表信息会在 state >> > > > 存储并且再次提交任务可以被访问到直接用吗? >> > > > >> > > > 谢谢, >> > > > 王磊 >> > > > >> > > > -- >> > > > wangl...@geekplus.com.cn >> > > > &

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 zhisheng
作。任务 cancel -s 之前已经存在的表信息会在 state > > > > 存储并且再次提交任务可以被访问到直接用吗? > > > > > > > > 谢谢, > > > > 王磊 > > > > > > > > -- > > > > wangl...@geekplus.com.cn > > > > > > > > >

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 Kurt Young
wangl...@geekplus.com.cn > > > > > > > > > *Sender:* Kurt Young > > > *Send Time:* 2020-03-11 12:54 > > > *Receiver:* wangl...@geekplus.com.cn > > > *cc:* user-zh > > > *Subject:* Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗? >

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 zhisheng
; > -- > > wangl...@geekplus.com.cn > > > > > > *Sender:* Kurt Young > > *Send Time:* 2020-03-11 12:54 > > *Receiver:* wangl...@geekplus.com.cn > > *cc:* user-zh > > *Subject:* Re: Re: flink sql join 可以有 state 存储

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 Kurt Young
state > 存储并且再次提交任务可以被访问到直接用吗? > > 谢谢, > 王磊 > > -- > wangl...@geekplus.com.cn > > > *Sender:* Kurt Young > *Send Time:* 2020-03-11 12:54 > *Receiver:* wangl...@geekplus.com.cn > *cc:* user-zh > *Subject:* Re: Re: flink sql joi

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-11 文章 wangl...@geekplus.com.cn
: user-zh Subject: Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗? sql client 目前还不支持这个功能。 Best, Kurt On Wed, Mar 11, 2020 at 11:35 AM wangl...@geekplus.com.cn wrote: Hi Kurt, 确实是可以 直接 flink cancel -s 保存状态。 但我是用 flink-sql-client 直接写 sql 提交的 job,再提交的时候怎样可以指定状态目录让这个任务从状态恢复呢? 谢谢, 王磊 Sender

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-10 文章 Kurt Young
com.cn> wrote: > >> Hi Kurt, >> 确实是可以 直接 flink cancel -s 保存状态。 >> 但我是用 flink-sql-client 直接写 sql 提交的 job,再提交的时候怎样可以指定状态目录让这个任务从状态恢复呢? >> >> 谢谢, >> 王磊 >> >> >> *Sender:* Kurt Young >> *Send Time:* 2020-03-11 10:38 >> *Receiver:

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-10 文章 Kurt Young
Sender:* Kurt Young > *Send Time:* 2020-03-11 10:38 > *Receiver:* user-zh > *Subject:* Re: flink sql join 可以有 state 存储并从 state 恢复数据吗? > 理论上来说,flink SQL的作业在编译完生成JobGraph并提交到集群上后,和Datastream的作业就没有什么本质的不同了。 > 应该也可以支持flink cancel -s 的功能,你可以先试下,如果碰到什么问题再看看。 > > Bes

Re: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-10 文章 wangl...@geekplus.com.cn
Hi Kurt, 确实是可以 直接 flink cancel -s 保存状态。 但我是用 flink-sql-client 直接写 sql 提交的 job,再提交的时候怎样可以指定状态目录让这个任务从状态恢复呢? 谢谢, 王磊 Sender: Kurt Young Send Time: 2020-03-11 10:38 Receiver: user-zh Subject: Re: flink sql join 可以有 state 存储并从 state 恢复数据吗? 理论上来说,flink SQL的作业在编译完生成JobGraph并提交到集群上后,和Datastream的作业就没有

Re: flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-10 文章 Kurt Young
理论上来说,flink SQL的作业在编译完生成JobGraph并提交到集群上后,和Datastream的作业就没有什么本质的不同了。 应该也可以支持flink cancel -s 的功能,你可以先试下,如果碰到什么问题再看看。 Best, Kurt On Wed, Mar 11, 2020 at 10:24 AM wangl...@geekplus.com.cn < wangl...@geekplus.com.cn> wrote: > 有两个表: > tableA: key valueA > tableB: key valueB > > 我之前用 flink state

flink sql join 可以有 state 存储并从 state 恢复数据吗?

2020-03-10 文章 wangl...@geekplus.com.cn
有两个表: tableA: key valueA tableB: key valueB 我之前用 flink state 的方式存储 tableA,tableB 的消息过来以后去 query 这个 state 得到 valueA 直接 写 flinkSQL 也可以实现这种功能,但这两个表有时间差,任务停止后重新提交会丢失部分 join 的结果。 flinkSQL 有没有类似 flink cancel -s 保存 state 的功能呢? 谢谢, 王磊