[FLINK-18685] JobClient.getAccumulators() blocks until streaming job has finished in local environment

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.13.0
• Component/s: API / DataStream
• Labels: pull-request-available starter
• Assignee: Etienne Chauchot
• Reporter: Robert Metzger
• Created: 23/Jul/20 11:43
• Updated: 28/May/21 08:14
• Resolved: 27/Jan/21 15:11

Description

Steps to reproduce:

JobClient client = env.executeAsync("Test");

CompletableFuture<JobStatus> status = client.getJobStatus();
LOG.info("status = " + status.get());

CompletableFuture<Map<String, Object>> accumulators = client.getAccumulators(StreamingJob.class.getClassLoader());
LOG.info("accus = " + accumulators.get(5, TimeUnit.SECONDS));

Actual behavior
The accumulators future will never complete for a streaming job when calling this just in your main() method from the IDE.

Expected behavior
Receive the accumulators of the running streaming job.
The JavaDocs of the method state the following: "Accumulators can be requested while it is running or after it has finished.".
While it is technically true that I can request accumulators, I was expecting as a user that I can access the accumulators of a running job.
Also, I can request accumulators if I submit the job to a cluster.

Issue Links

• links to: GitHub Pull Request #14558