你可以在 mysqlSinkFunction 中攒 buffer，在 timer trigger 或者 checkpoint 时 flush mysql database，以及 output。
On Mon, 13 Jul 2020 at 15:36, jindy_liu <286729...@qq.com> wrote: > > > 如果可以chain在一起，这个可以保证顺序性，我去试试。 > > 这里再追问下，实际中，如里单流源里的数据也要顺序处理，可以设置并行度为1； > > 这里可能也要考虑下mysqlSinkFunction里的sink效率问题，需要积累一些数据再sink，这里可以做到跟kafka > sink的batch_size和linger.ms配合联动吗？比如满1000条，或超过1s，就同时sink? > > 谢谢~ > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
