[flink] branch master updated: [hotfix] [tests] JobManager -> Dispatcher in DispatcherProcess

[tr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new e8bf552  [hotfix] [tests] JobManager -> Dispatcher in DispatcherProcess
e8bf552 is described below

commit e8bf552f9586743563d79c17ed84bc32040df6c0
Author: 陈梓立 <wa...@gmail.com>
AuthorDate: Thu Oct 11 14:40:17 2018 +0800

    [hotfix] [tests] JobManager -> Dispatcher in DispatcherProcess
---
 .../flink/runtime/testutils/DispatcherProcess.java | 27 +++++++++++-----------
 1 file changed, 13 insertions(+), 14 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/DispatcherProcess.java b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/DispatcherProcess.java
index 85d3caa..d8e2b6b 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/DispatcherProcess.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/DispatcherProcess.java
@@ -25,7 +25,6 @@ import org.apache.flink.configuration.RestOptions;
 import org.apache.flink.runtime.dispatcher.Dispatcher;
 import org.apache.flink.runtime.entrypoint.ClusterEntrypoint;
 import org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint;
-import org.apache.flink.runtime.jobmanager.JobManager;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -41,22 +40,22 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
  */
 public class DispatcherProcess extends TestJvmProcess {
 
-	private static final Logger LOG = LoggerFactory.getLogger(JobManagerProcess.class);
+	private static final Logger LOG = LoggerFactory.getLogger(DispatcherProcess.class);
 
-	/** ID for this JobManager. */
+	/** ID for this Dispatcher. */
 	private final int id;
 
-	/** The configuration for the JobManager. */
+	/** The configuration for the Dispatcher. */
 	private final Configuration config;
 
-	/** Configuration parsed as args for {@link JobManagerProcess.JobManagerProcessEntryPoint}. */
+	/** Configuration parsed as args for {@link DispatcherProcess.DispatcherProcessEntryPoint}. */
 	private final String[] jvmArgs;
 
 	/**
-	 * Creates a {@link JobManager} running in a separate JVM.
+	 * Creates a {@link Dispatcher} running in a separate JVM.
 	 *
-	 * @param id     ID for the JobManager
-	 * @param config Configuration for the job manager process
+	 * @param id     ID for the Dispatcher
+	 * @param config Configuration for the dispatcher process
 	 *
 	 * @throws Exception
 	 */
@@ -78,7 +77,7 @@ public class DispatcherProcess extends TestJvmProcess {
 
 	@Override
 	public String getName() {
-		return "JobManager " + id;
+		return "Dispatcher " + id;
 	}
 
 	@Override
@@ -97,11 +96,11 @@ public class DispatcherProcess extends TestJvmProcess {
 
 	@Override
 	public String toString() {
-		return String.format("JobManagerProcess(id=%d)", id);
+		return String.format("DispatcherProcess(id=%d)", id);
 	}
 
 	/**
-	 * Entry point for the JobManager process.
+	 * Entry point for the Dispatcher process.
 	 */
 	public static class DispatcherProcessEntryPoint {
 
@@ -110,8 +109,8 @@ public class DispatcherProcess extends TestJvmProcess {
 		/**
 		 * Entrypoint of the DispatcherProcessEntryPoint.
 		 *
-		 * <p>Other arguments are parsed to a {@link Configuration} and passed to the
-		 * JobManager, for instance: <code>--high-availability ZOOKEEPER --high-availability.zookeeper.quorum
+		 * <p>Other arguments are parsed to a {@link Configuration} and passed to the Dispatcher,
+		 * for instance: <code>--high-availability ZOOKEEPER --high-availability.zookeeper.quorum
 		 * "xyz:123:456"</code>.
 		 */
 		public static void main(String[] args) {
@@ -128,7 +127,7 @@ public class DispatcherProcess extends TestJvmProcess {
 				ClusterEntrypoint.runClusterEntrypoint(clusterEntrypoint);
 			}
 			catch (Throwable t) {
-				LOG.error("Failed to start JobManager process", t);
+				LOG.error("Failed to start Dispatcher process", t);
 				System.exit(1);
 			}
 		}