如果可以chain在一起,这个可以保证顺序性,我去试试。
这里再追问下,实际中,如里单流源里的数据也要顺序处理,可以设置并行度为1; 这里可能也要考虑下mysqlSinkFunction里的sink效率问题,需要积累一些数据再sink,这里可以做到跟kafka sink的batch_size和linger.ms配合联动吗?比如满1000条,或超过1s,就同时sink? 谢谢~ -- Sent from: http://apache-flink.147419.n8.nabble.com/
如果可以chain在一起,这个可以保证顺序性,我去试试。
这里再追问下,实际中,如里单流源里的数据也要顺序处理,可以设置并行度为1; 这里可能也要考虑下mysqlSinkFunction里的sink效率问题,需要积累一些数据再sink,这里可以做到跟kafka sink的batch_size和linger.ms配合联动吗?比如满1000条,或超过1s,就同时sink? 谢谢~ -- Sent from: http://apache-flink.147419.n8.nabble.com/