nt的dag优化和StreamTableEnvironment较丰富api会不会统一？
>
> Best,
> Junbao Zhang
>
> 发件人: Benchao Li
> 发送时间: 2020年5月28日 17:35
> 收件人: user-zh
> 主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
>
> Hi,
>
> 时间差了13个小时这个比较奇怪，我理解不应该出现这个问
ronment类似于TableEnvironment的Dag优化有版本规划吗？未来TableEnvironment的dag优化和StreamTableEnvironment较丰富api会不会统一？
> > >
> > > Best,
> > > Junbao Zhang
> > > ____________
> > > 发件人: Benchao Li
> > > 发送时间: 2020年5月28日 17:35
> > > 收件人: user-zh
&
ironment较丰富api会不会统一？
> >
> > Best,
> > Junbao Zhang
> >
> > 发件人: Benchao Li
> > 发送时间: 2020年5月28日 17:35
> > 收件人: user-zh
> > 主题: Re: 疑问：flink sql
> 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
> >
> > Hi,
> >
> >
nt的dag优化和StreamTableEnvironment较丰富api会不会统一？
>
> Best,
> Junbao Zhang
>
> 发件人: Benchao Li
> 发送时间: 2020年5月28日 17:35
> 收件人: user-zh
> 主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
>
> Hi,
>
> 时间差了13个小时这个比较奇怪，
TAMP函数。另外问一个问题，使用TableEnvironment怎么设置checkpoint?
>
>
>
>
> Best,
> Junbao Zhang
>
> 发件人: Benchao Li
> 发送时间: 2020年5月28日 17:05
> 收件人: user-zh
> 主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
>
> 嗯，是的
ironment怎么设置checkpoint?
> >
> >
> >
> >
> > Best,
> > Junbao Zhang
> > ________
> > 发件人: Benchao Li
> > 发送时间: 2020年5月28日 17:05
> > 收件人: user-zh
> > 主题: Re: 疑问：flink sql
> 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表
AMP函数。另外问一个问题，使用TableEnvironment怎么设置checkpoint?
>
>
>
>
> Best,
> Junbao Zhang
>
> 发件人: Benchao Li
> 发送时间: 2020年5月28日 17:05
> 收件人: user-zh
> 主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
>
> 嗯，是的
Best,
> Junbao Zhang
>
> 发件人: Benchao Li
> 发送时间: 2020年5月28日 15:59
> 收件人: user-zh
> 主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
>
>
> 如果你的tEnv用的是TableEnvironment，而不是StreamTableEnvironment的话，两个insert会公用前面的source，也就是会只读取a
Best,
> Junbao Zhang
>
> 发件人: Benchao Li
> 发送时间: 2020年5月28日 15:59
> 收件人: user-zh
> 主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
>
>
> 如果你的tEnv用的是TableEnvironment，而不是StreamTableEnvironment的话，两个insert会公用前面的source，也就是会只读取a表一次，然后分别给下游c
Hi, Benchao：
谢谢回复，经过测试确实是这样，也就是同一个TableEnvironment下，如果有多条insert语句访问同一个表，该表的数据只消费一次？
Best,
Junbao Zhang
发件人: Benchao Li
发送时间: 2020年5月28日 15:59
收件人: user-zh
主题: Re: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交
如果你的tEnv用的是TableEnvironment
如果你的tEnv用的是TableEnvironment，而不是StreamTableEnvironment的话，两个insert会公用前面的source，也就是会只读取a表一次，然后分别给下游c和d用。
wind.fly@outlook.com 于2020年5月28日周四 下午3:14写道：
> Hi,all:
> 当前使用版本flink 1.10.0，使用blink planner，假如有如下代码：
>
> tEnv.createTemporaryView("b", tEnv.sqlQuery("select * from a"));
>
Hi,all:
当前使用版本flink 1.10.0，使用blink planner，假如有如下代码：
tEnv.createTemporaryView("b", tEnv.sqlQuery("select * from a"));
tEnv.sqlUpdate("insert into c select * from b where b.con1 = '1'");
tEnv.sqlUpdate("insert into d select * from b where b.con1 = '2'");
其中a是kafka表，connector属性为：
12 matches
Mail list logo
