[GitHub] [flink] zhuxiaoshang commented on pull request #13162: [FLINK-18685][API / DataStream]JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-08-22 Thread GitBox
zhuxiaoshang commented on pull request #13162: URL: https://github.com/apache/flink/pull/13162#issuecomment-678609051 @rmetzger ,according to your solution,UnalignedCheckpointCompatibilityITCase#test still run failed when the type is save point.From my analyse,the root cause is when the

[GitHub] [flink] zhuxiaoshang commented on pull request #13162: [FLINK-18685][API / DataStream]JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-08-20 Thread GitBox
zhuxiaoshang commented on pull request #13162: URL: https://github.com/apache/flink/pull/13162#issuecomment-677492835 @rmetzger Sorry for the failing,what i think is make the getAccumulators() can be async invoked.But the actual behavior is not my expect. When i debug the code,the