Repository: flink Updated Branches: refs/heads/master 4c883e342 -> 17e8664aa
[hotfix] [REST] Fix WebMonitorEndpoint that missing parameters while initializing handlers This closes #5322. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17e8664a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17e8664a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/17e8664a Branch: refs/heads/master Commit: 17e8664aa6e2915c368e8eb75c6ae5e3b1942239 Parents: 4c883e3 Author: biao.liub <biao.l...@alibaba-inc.com> Authored: Sat Jan 20 13:26:29 2018 +0800 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Sun Jan 21 10:38:45 2018 +0100 ---------------------------------------------------------------------- .../job/SubtaskExecutionAttemptAccumulatorsHeaders.java | 6 +++--- .../apache/flink/runtime/webmonitor/WebMonitorEndpoint.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/17e8664a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsHeaders.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsHeaders.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsHeaders.java index d162156..662e87c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsHeaders.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsHeaders.java @@ -31,7 +31,7 @@ import org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseSt /** * Message headers for the {@link SubtaskExecutionAttemptAccumulatorsHandler}. */ -public class SubtaskExecutionAttemptAccumulatorsHeaders implements MessageHeaders<EmptyRequestBody, SubtaskExecutionAttemptDetailsInfo, SubtaskAttemptMessageParameters> { +public class SubtaskExecutionAttemptAccumulatorsHeaders implements MessageHeaders<EmptyRequestBody, SubtaskExecutionAttemptAccumulatorsInfo, SubtaskAttemptMessageParameters> { private static final SubtaskExecutionAttemptAccumulatorsHeaders INSTANCE = new SubtaskExecutionAttemptAccumulatorsHeaders(); @@ -58,8 +58,8 @@ public class SubtaskExecutionAttemptAccumulatorsHeaders implements MessageHeader } @Override - public Class<SubtaskExecutionAttemptDetailsInfo> getResponseClass() { - return SubtaskExecutionAttemptDetailsInfo.class; + public Class<SubtaskExecutionAttemptAccumulatorsInfo> getResponseClass() { + return SubtaskExecutionAttemptAccumulatorsInfo.class; } @Override http://git-wip-us.apache.org/repos/asf/flink/blob/17e8664a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java b/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java index f0cfb5e..e432752 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java @@ -376,7 +376,7 @@ public class WebMonitorEndpoint<T extends RestfulGateway> extends RestServerEndp leaderRetriever, timeout, responseHeaders, - null, + SubtaskExecutionAttemptDetailsHeaders.getInstance(), executionGraphCache, executor, metricFetcher); @@ -386,7 +386,7 @@ public class WebMonitorEndpoint<T extends RestfulGateway> extends RestServerEndp leaderRetriever, timeout, responseHeaders, - null, + SubtaskExecutionAttemptAccumulatorsHeaders.getInstance(), executionGraphCache, executor ); @@ -396,7 +396,7 @@ public class WebMonitorEndpoint<T extends RestfulGateway> extends RestServerEndp leaderRetriever, timeout, responseHeaders, - null, + SubtaskCurrentAttemptDetailsHeaders.getInstance(), executionGraphCache, executor, metricFetcher
