Re: pyflink udf中发送rest api会导致udf被调用两次

[lgs]

代码顺序是指我先写第一个sink的代码，再写第二个sink的代码。

我设置了'connector.write.flush.max-rows' = '1'
第一个sink没有窗口，所以直接写了

第二个sink有窗口，所以是会在一个小时的最后触发。

可能这样就能保证第二个sink能够读到最新的数据。




--
Sent from: http://apache-flink.147419.n8.nabble.com/