[ https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389173#comment-16389173 ]
ASF GitHub Bot commented on FLINK-8756: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172755830 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -389,6 +393,27 @@ public String cancelWithSavepoint(JobID jobId, @Nullable String savepointDirecto }); } + @Override + public Map<String, Object> getAccumulators(final JobID jobID) throws Exception { --- End diff -- we should also override `Map<String, Object> getAccumulators(JobID jobID, ClassLoader loader)` > Support ClusterClient.getAccumulators() in RestClusterClient > ------------------------------------------------------------ > > Key: FLINK-8756 > URL: https://issues.apache.org/jira/browse/FLINK-8756 > Project: Flink > Issue Type: Improvement > Components: Client > Affects Versions: 1.5.0 > Reporter: Aljoscha Krettek > Assignee: vinoyang > Priority: Blocker > Fix For: 1.5.0 > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)