From 2b1972e6be6dded73c3886cf5347f842c4b49a56 Mon Sep 17 00:00:00 2001
From: yanghua <yanghua1127@gmail.com>
Date: Wed, 9 May 2018 17:27:26 +0800
Subject: [PATCH] [FLINK-9321] Rename SubtasksAllAccumulatorsHandlers

---
 ...sHandlers.java => SubtasksAllAccumulatorsHeaders.java} | 8 ++++----
 .../flink/runtime/webmonitor/WebMonitorEndpoint.java      | 4 ++--
 2 files changed, 6 insertions(+), 6 deletions(-)
 rename flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{SubtasksAllAccumulatorsHandlers.java => SubtasksAllAccumulatorsHeaders.java} (84%)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksAllAccumulatorsHandlers.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksAllAccumulatorsHeaders.java
similarity index 84%
rename from flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksAllAccumulatorsHandlers.java
rename to flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksAllAccumulatorsHeaders.java
index e178c93aa6c97..21ec62e9722eb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksAllAccumulatorsHandlers.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksAllAccumulatorsHeaders.java
@@ -27,9 +27,9 @@
 /**
  * Message headers for the {@link SubtasksAllAccumulatorsHandler}.
  */
-public class SubtasksAllAccumulatorsHandlers implements MessageHeaders<EmptyRequestBody, SubtasksAllAccumulatorsInfo, JobVertexMessageParameters> {
+public class SubtasksAllAccumulatorsHeaders implements MessageHeaders<EmptyRequestBody, SubtasksAllAccumulatorsInfo, JobVertexMessageParameters> {
 
-	private static final SubtasksAllAccumulatorsHandlers INSTANCE = new SubtasksAllAccumulatorsHandlers();
+	private static final SubtasksAllAccumulatorsHeaders INSTANCE = new SubtasksAllAccumulatorsHeaders();
 
 	public static final String URL = "/jobs" +
 		"/:" + JobIDPathParameter.KEY +
@@ -37,7 +37,7 @@ public class SubtasksAllAccumulatorsHandlers implements MessageHeaders<EmptyRequ
 		"/:" + JobVertexIdPathParameter.KEY +
 		"/subtasks/accumulators";
 
-	private SubtasksAllAccumulatorsHandlers() {}
+	private SubtasksAllAccumulatorsHeaders() {}
 
 	@Override
 	public Class<EmptyRequestBody> getRequestClass() {
@@ -69,7 +69,7 @@ public String getTargetRestEndpointURL() {
 		return URL;
 	}
 
-	public static SubtasksAllAccumulatorsHandlers getInstance() {
+	public static SubtasksAllAccumulatorsHeaders getInstance() {
 		return INSTANCE;
 	}
 }
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 ef6721b044830..b524cd7b954e3 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
@@ -96,7 +96,7 @@
 import org.apache.flink.runtime.rest.messages.JobVertexDetailsHeaders;
 import org.apache.flink.runtime.rest.messages.JobVertexTaskManagersHeaders;
 import org.apache.flink.runtime.rest.messages.JobsOverviewHeaders;
-import org.apache.flink.runtime.rest.messages.SubtasksAllAccumulatorsHandlers;
+import org.apache.flink.runtime.rest.messages.SubtasksAllAccumulatorsHeaders;
 import org.apache.flink.runtime.rest.messages.SubtasksTimesHeaders;
 import org.apache.flink.runtime.rest.messages.TerminationModeQueryParameter;
 import org.apache.flink.runtime.rest.messages.YarnCancelJobTerminationHeaders;
@@ -327,7 +327,7 @@ protected List<Tuple2<RestHandlerSpecification, ChannelInboundHandler>> initiali
 			leaderRetriever,
 			timeout,
 			responseHeaders,
-			SubtasksAllAccumulatorsHandlers.getInstance(),
+			SubtasksAllAccumulatorsHeaders.getInstance(),
 			executionGraphCache,
 			executor);