添加launch main 本地的日志打印

Author: xuchao

launcher/pom.xml

@@ -29,6 +29,12 @@
             <version>1.2.17</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-log4j12</artifactId>
+            <version>1.6.1</version>
+        </dependency>
+
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>

launcher/src/main/java/com/dtstack/flink/sql/launcher/LauncherMain.java

@@ -41,6 +41,8 @@
 import org.apache.flink.runtime.jobgraph.JobGraph;
 import org.apache.flink.runtime.jobgraph.SavepointRestoreSettings;
 import org.apache.flink.util.FileUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.File;
 import java.io.IOException;
@@ -57,6 +59,8 @@
  */
 
 public class LauncherMain {
+
+    private static final Logger LOG = LoggerFactory.getLogger(LauncherMain.class);
     private static final String CORE_JAR = "core";
 
     private static String SP = File.separator;
@@ -68,9 +72,13 @@ private static String getLocalCoreJarPath(String localSqlRootJar) throws Excepti
     }
 
     public static void main(String[] args) throws Exception {
+
+        LOG.info("----start----");
+
         if (args.length == 1 && args[0].endsWith(".json")){
             args = parseJson(args);
         }
+
         OptionParser optionParser = new OptionParser(args);
         Options launcherOptions = optionParser.getOptions();
         String mode = launcherOptions.getMode();

launcher/src/main/resource/log4j.properties

@@ -0,0 +1,7 @@
+#控制台输出：
+log4j.rootLogger = INFO,consoleAppender
+log4j.appender.consoleAppender = org.apache.log4j.ConsoleAppender
+log4j.appender.console.Target = System.out
+log4j.appender.consoleAppender.layout = org.apache.log4j.PatternLayout
+log4j.appender.consoleAppender.layout.ConversionPattern =%d %-5p %m %n
+log4j.appender.consoleAppender.ImmediateFlush = true