You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/08/20 09:39:41 UTC

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

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 returned CompletableFuture of 'miniCluster.getExecutionGraph(jobID)' is 'not completed',so the accumulators is empty.
   Could you give some suggestions to me?Thanks a lot.
   
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org