1.请问Latch是如何在多个TaskManager之间起到同步作业的？并没有看到有关全局同步相关的代码。 2.在JdbcOutputFormat中close()方法中执行了postSql，但是flink的task会在close之后才会flush数据，请问如何保证执行postSql的时候数据都已经flush完成？
1.请问Latch是如何在多个TaskManager之间起到同步作业的？并没有看到有关全局同步相关的代码。
2.在JdbcOutputFormat中close()方法中执行了postSql，但是flink的task会在close之后才会flush数据，请问如何保证执行postSql的时候数据都已经flush完成？