如果可以chain在一起,这个可以保证顺序性,我去试试。

这里再追问下,实际中,如里单流源里的数据也要顺序处理,可以设置并行度为1;

这里可能也要考虑下mysqlSinkFunction里的sink效率问题,需要积累一些数据再sink,这里可以做到跟kafka
sink的batch_size和linger.ms配合联动吗?比如满1000条,或超过1s,就同时sink?

谢谢~




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

回复