..@foxmail.com>>
> 抄 送：user-zh mailto:user-zh@flink.apache.org>>
> 主 题：Re: 关于statement输出结果疑问
>
> 奥，那你理解错了。这里面其实细分成2种情况：
> - sink1和sink2，通过operator
> chain之后，和source节点位于同一个物理节点：由于执行的时候，在一个JVM里，每处理一条数据，先发送给其中一个sink，再发送给另外一个sink。然后处理下一条数据
> - sink1
> 和sink2，和source节点处于不同
Hi,大佬,想问下如果使用Lazy调度模式,情况会是什么样子
--
发件人：Dian Fu
发送时间：2021年3月15日(星期一) 15:49
收件人：刘杰鸿
抄 送：user-zh
主 题：Re: 关于statement输出结果疑问
奥，那你理解错了。这里面其实细分成2种情况：
- sink1和sink2，通过operator
chain之后，和source节点位于同一个物理节点：由于执行的时候，在一个JVM里，每处理一条数据，先发送给其中一个
uot;user-zh";"刘杰鸿";
> 主题: Re: 关于statement输出结果疑问
>
> 可以说一下为什么你觉得输出结果应该是1，2，1，2吗？
>
> 个人觉得现在的输出结果应该没有问题。比如第1条数据，先发送到sink1，再发送到sink2，所以打印了2个1；然后处理第二条数据，打印了2个2
>
> On Mon, Mar 8, 2021 at 9:42 AM 刘杰鸿 <mailto:wushang...@foxmail.com>> wrote:
&g
可以说一下为什么你觉得输出结果应该是1，2，1，2吗？
个人觉得现在的输出结果应该没有问题。比如第1条数据，先发送到sink1，再发送到sink2，所以打印了2个1；然后处理第二条数据，打印了2个2
On Mon, Mar 8, 2021 at 9:42 AM 刘杰鸿 wrote:
> from pyflink.table import EnvironmentSettings, StreamTableEnvironment
>
> env_settings =
> EnvironmentSettings.new_instance().in_streaming_mode().use_b
