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

["Robert Metzger (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger closed FLINK-18685.
----------------------------------
    Fix Version/s: 1.13.0
       Resolution: Fixed

> JobClient.getAccumulators() blocks until streaming job has finished in local environment
> ----------------------------------------------------------------------------------------
>
>                 Key: FLINK-18685
>                 URL: https://issues.apache.org/jira/browse/FLINK-18685
>             Project: Flink
>          Issue Type: Bug
>          Components: API / DataStream
>    Affects Versions: 1.11.0
>            Reporter: Robert Metzger
>            Assignee: Etienne Chauchot
>            Priority: Major
>              Labels: pull-request-available, starter
>             Fix For: 1.13.0
>
>
> *Steps to reproduce:*
> {code:java}
> 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));
> {code}
> *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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)