请教个Flink sql问题

[占英华]

Flink sql的dml语句可以将结果写入不同的sink表中吗？如果可以可以怎么处理？

[nobleyd]

应该可以，先说下我SQL也是刚刚开始学习哈。

你写2个SQL肯定是可以达到的，如果你是希望2个SQL在同一个作业中，也是可以的。
不清楚你是啥开发SQL，比如zeppelin的话，有个runAsOne的设置。如果是代码的话，好像有个StatementSet的概念。

占英华 <[hidden email]> 于2020年12月19日周六 上午9:32写道：

> Flink sql的dml语句可以将结果写入不同的sink表中吗？如果可以可以怎么处理？

[hailongwang]

可以的，比如将结果写入table1，table2 ……
Insert into table1 ……;
Insert into table2 ……;
…………


Best,
Hailong
在 2020-12-19 08:30:23，"占英华" <[hidden email]> 写道：
>Flink sql的dml语句可以将结果写入不同的sink表中吗？如果可以可以怎么处理？

[占英华]

这样是不是第一条select和第二条的select出来的结果会有差异，因为执行第一条有耗时，第二条执行时查询的结果是在耗时后查询得到的

> 在 2020年12月21日，11:14，hailongwang <[hidden email]> 写道：
>
> 
>
> 可以的，比如将结果写入table1，table2 ……
> Insert into table1 ……;
> Insert into table2 ……;
> …………
>
>
> Best,
> Hailong
>> 在 2020-12-19 08:30:23，"占英华" <[hidden email]> 写道：
>> Flink sql的dml语句可以将结果写入不同的sink表中吗？如果可以可以怎么处理？

[hailongwang]

不是的。在提交运行之后，如果那两个 insert 是从同一张表 select 出来的话，是会分流发送到 table1 和 table2，并没有先后顺序。
在 2020-12-21 10:45:25，"占英华" <[hidden email]> 写道：

>这样是不是第一条select和第二条的select出来的结果会有差异，因为执行第一条有耗时，第二条执行时查询的结果是在耗时后查询得到的
>
>> 在 2020年12月21日，11:14，hailongwang <[hidden email]> 写道：
>>
>> 
>>
>> 可以的，比如将结果写入table1，table2 ……
>> Insert into table1 ……;
>> Insert into table2 ……;
>> …………
>>
>>
>> Best,
>> Hailong
>>> 在 2020-12-19 08:30:23，"占英华" <[hidden email]> 写道：
>>> Flink sql的dml语句可以将结果写入不同的sink表中吗？如果可以可以怎么处理？

[占英华]

学习了，感谢回复！

> 在 2020年12月21日，20:39，hailongwang <[hidden email]> 写道：
>
> 
>
>
> 不是的。在提交运行之后，如果那两个 insert 是从同一张表 select 出来的话，是会分流发送到 table1 和 table2，并没有先后顺序。
>> 在 2020-12-21 10:45:25，"占英华" <[hidden email]> 写道：
>> 这样是不是第一条select和第二条的select出来的结果会有差异，因为执行第一条有耗时，第二条执行时查询的结果是在耗时后查询得到的
>>
>>>> 在 2020年12月21日，11:14，hailongwang <[hidden email]> 写道：
>>>
>>> 
>>>
>>> 可以的，比如将结果写入table1，table2 ……
>>> Insert into table1 ……;
>>> Insert into table2 ……;
>>> …………
>>>
>>>
>>> Best,
>>> Hailong
>>>> 在 2020-12-19 08:30:23，"占英华" <[hidden email]> 写道：
>>>> Flink sql的dml语句可以将结果写入不同的sink表中吗？如果可以可以怎么处理？