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

[lgs]

这次可以了。谢谢

另外还有一个问题请教一下：
我实际上是有另一个sink，source是同一个。
第一个sink是直接保存kafka数据到DB。
第二个sink是读取kafka，tumble window，然后在udf里面去读取DB。

要怎么样保证第一个sink写完了DB，然后第二个sink的udf能读取到最新的数据？

代码的顺序就能保证吗？




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