V1.7.0 dev-以命令行参数的方式指定detached

flinkx-core/pom.xml

@@ -131,6 +131,8 @@
                             <artifactSet>
                                 <includes>
                                     <include>com.google.guava:*</include>
+                                    <include>ch.qos.logback:*</include>
+                                    <include>org.slf4j:*</include>
                                 </includes>
                             </artifactSet>
                         </configuration>

flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/ClusterClientFactory.java

@@ -75,7 +75,7 @@ public static ClusterClient createStandaloneClient(LauncherOptions launcherOptio
         InetSocketAddress address = AkkaUtils.getInetSocketAddressFromAkkaURL(connectionInfo.getAddress());
         config.setString(JobManagerOptions.ADDRESS, address.getAddress().getHostName());
         config.setInteger(JobManagerOptions.PORT, address.getPort());
-        clusterClient.setDetached(true);
+        clusterClient.setDetached(launcherOptions.getDetached());
         return clusterClient;
     }
 
@@ -128,7 +128,7 @@ public static ClusterClient createYarnClient(LauncherOptions launcherOptions) {
 
                 AbstractYarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(config, yarnConf, ".", yarnClient, false);
                 ClusterClient clusterClient = clusterDescriptor.retrieve(applicationId);
-                clusterClient.setDetached(true);
+                clusterClient.setDetached(launcherOptions.getDetached());
                 return clusterClient;
             } catch(Exception e) {
                 throw new RuntimeException(e);

flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/LauncherOptionParser.java

@@ -52,6 +52,8 @@ public class LauncherOptionParser {
 
     public static final String OPTION_FLINK_LIB_JAR = "flinkLibJar";
 
+    public static final String OPTION_DETACHED = "detached";
+
     private Options options = new Options();
 
     private BasicParser parser = new BasicParser();
@@ -67,6 +69,7 @@ public LauncherOptionParser(String[] args) {
         options.addOption(OPTION_QUEUE, true, "yarn job queue");
         options.addOption(OPTION_FLINK_CONF_PROP, true, "flink perjob conf prop");
         options.addOption(OPTION_FLINK_LIB_JAR, true, "flink lib jar");
+        options.addOption(OPTION_DETACHED, false, "detached mode");
 
         try {
             CommandLine cl = parser.parse(options, args);
@@ -111,6 +114,9 @@ public LauncherOptionParser(String[] args) {
                 launcherOptions.setConfProp(confProp);
             }
 
+            if (cl.hasOption(OPTION_DETACHED)) {
+                launcherOptions.setDetached(true);
+            }
 
         } catch (Exception e) {
             printUsage();

flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/LauncherOptions.java

@@ -48,6 +48,8 @@ public class LauncherOptions {
 
       private String confProp;
 
+      private boolean detached;
+
     public int getParallelism() {
         return parallelism;
     }
@@ -135,4 +137,12 @@ public String getConfProp() {
     public void setConfProp(String confProp) {
         this.confProp = confProp;
     }
+
+    public boolean getDetached() {
+        return detached;
+    }
+
+    public void setDetached(boolean detached) {
+        this.detached = detached;
+    }
 }