remove unuse param

todd5167 · todd5167 · commit f18bdb63c66b · 2019-12-18T18:43:00.000+08:00
diff --git a/launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java b/launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java
@@ -62,7 +62,7 @@ public static ClusterClient createClusterClient(Options launcherOptions) throws
         if (mode.equals(ClusterMode.standalone.name())) {
             return createStandaloneClient(launcherOptions);
         } else if (mode.equals(ClusterMode.yarn.name())) {
-            return createYarnSessionClient(launcherOptions, mode);
+            return createYarnSessionClient(launcherOptions);
         }
         throw new IllegalArgumentException("Unsupported cluster client type: ");
     }
@@ -82,7 +82,7 @@ public static ClusterClient createStandaloneClient(Options launcherOptions) thro
         return clusterClient;
     }
 
-    public static ClusterClient createYarnSessionClient(Options launcherOptions, String mode) {
+    public static ClusterClient createYarnSessionClient(Options launcherOptions) {
 
         String flinkConfDir = launcherOptions.getFlinkconf();
         Configuration config = GlobalConfiguration.loadConfiguration(flinkConfDir);

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ public static ClusterClient createClusterClient(Options launcherOptions) throws`
`62`	`62`	`if (mode.equals(ClusterMode.standalone.name())) {`
`63`	`63`	`return createStandaloneClient(launcherOptions);`
`64`	`64`	`} else if (mode.equals(ClusterMode.yarn.name())) {`
`65`		`- return createYarnSessionClient(launcherOptions, mode);`
	`65`	`+ return createYarnSessionClient(launcherOptions);`
`66`	`66`	`}`
`67`	`67`	`throw new IllegalArgumentException("Unsupported cluster client type: ");`
`68`	`68`	`}`
`@@ -82,7 +82,7 @@ public static ClusterClient createStandaloneClient(Options launcherOptions) thro`
`82`	`82`	`return clusterClient;`
`83`	`83`	`}`
`84`	`84`
`85`		`- public static ClusterClient createYarnSessionClient(Options launcherOptions, String mode) {`
	`85`	`+ public static ClusterClient createYarnSessionClient(Options launcherOptions) {`
`86`	`86`
`87`	`87`	`String flinkConfDir = launcherOptions.getFlinkconf();`
`88`	`88`	`Configuration config = GlobalConfiguration.loadConfiguration(flinkConfDir);`