[feat][launcher] 默认绑定log4j并添加配置文件

Author: lvyanquan

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

@@ -67,7 +67,6 @@ public class Launcher {
     public static final String MAIN_CLASS = "com.dtstack.flinkx.Main";
 
     public static void main(String[] args) throws Exception {
-        setLogLevel(Level.DEBUG.toString());
         OptionParser optionParser = new OptionParser(args);
         Options launcherOptions = optionParser.getOptions();
         findDefaultConfigDir(launcherOptions);
@@ -267,11 +266,4 @@ private static String readJob(String job) {
             throw new RuntimeException(e);
         }
     }
-
-    private static void setLogLevel(String level) {
-        LoggerContext loggerContext = (LoggerContext) LoggerFactory.getILoggerFactory();
-        //设置全局日志级别
-        ch.qos.logback.classic.Logger logger = loggerContext.getLogger("root");
-        logger.setLevel(Level.toLevel(level));
-    }
 }

flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/perJob/PerJobClusterClientBuilder.java

@@ -98,13 +98,13 @@ public YarnClusterDescriptor createPerJobClusterDescriptor(Options launcherOptio
         } else {
             throw new IllegalArgumentException("The Flink jar path is null");
         }
-        File logback = new File(launcherOptions.getFlinkconf()+ File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOGBACK_NAME);
-        if(logback.exists()){
-            flinkConfig.setString(YarnConfigOptionsInternal.APPLICATION_LOG_CONFIG_FILE, launcherOptions.getFlinkconf()+ File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOGBACK_NAME);
-        }else{
-            File log4j = new File(launcherOptions.getFlinkconf()+ File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOG4J_NAME);
-            if(log4j.exists()){
-                flinkConfig.setString(YarnConfigOptionsInternal.APPLICATION_LOG_CONFIG_FILE, launcherOptions.getFlinkconf()+ File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOG4J_NAME);
+        File log4j = new File(launcherOptions.getFlinkconf()+ File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOG4J_NAME);
+        if(log4j.exists()){
+            flinkConfig.setString(YarnConfigOptionsInternal.APPLICATION_LOG_CONFIG_FILE, launcherOptions.getFlinkconf()+ File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOG4J_NAME);
+        }else {
+            File logback = new File(launcherOptions.getFlinkconf() + File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOGBACK_NAME);
+            if (logback.exists()) {
+                flinkConfig.setString(YarnConfigOptionsInternal.APPLICATION_LOG_CONFIG_FILE, launcherOptions.getFlinkconf() + File.separator + FlinkYarnSessionCli.CONFIG_FILE_LOGBACK_NAME);
             }
 
         }

flinkx-launcher/src/main/resources/log4j.properties

@@ -0,0 +1,48 @@
+#############
+# 输出到控制台
+#############
+
+# log4j.rootLogger日志输出类别和级别：只输出不低于该级别的日志信息 DEBUG < INFO < WARN < ERROR < FATAL
+# WARN：日志级别     CONSOLE：输出位置自己定义的一个名字       logfile：输出位置自己定义的一个名字
+log4j.rootLogger=INFO,CONSOLE,logfile
+# 配置CONSOLE输出到控制台
+log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
+# 配置CONSOLE设置为自定义布局模式
+log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
+# 配置CONSOLE日志的输出格式  2019-08-22 22:52:12,000  %r耗费毫秒数 %p日志的优先级 %t线程名 %C所属类名通常为全类名 %L代码中的行号 %x线程相关联的NDC %m日志 %n换行
+log4j.appender.CONSOLE.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} - %-4r %-5p [%t] %C:%m%n
+
+################
+# 输出到日志文件中
+################
+
+## 配置logfile输出到文件中 文件大小到达指定尺寸的时候产生新的日志文件
+#log4j.appender.logfile=org.apache.log4j.RollingFileAppender
+## 保存编码格式
+#log4j.appender.logfile.Encoding=UTF-8
+## 输出文件位置此为项目根目录下的logs文件夹中
+#log4j.appender.logfile.File=logs/root.log
+## 后缀可以是KB,MB,GB达到该大小后创建新的日志文件
+#log4j.appender.logfile.MaxFileSize=10MB
+## 设置滚定文件的最大值3 指可以产生root.log.1、root.log.2、root.log.3和root.log四个日志文件
+#log4j.appender.logfile.MaxBackupIndex=3
+## 配置logfile为自定义布局模式
+#log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
+#log4j.appender.logfile.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %F %p %m%n
+#
+###########################
+## 对不同的类输出不同的日志文件
+###########################
+#
+## club.bagedate包下的日志单独输出
+#log4j.logger.club.bagedate=DEBUG,bagedate
+## 设置为false该日志信息就不会加入到rootLogger中了
+#log4j.additivity.club.bagedate=false
+## 下面就和上面配置一样了
+#log4j.appender.bagedate=org.apache.log4j.RollingFileAppender
+#log4j.appender.bagedate.Encoding=UTF-8
+#log4j.appender.bagedate.File=logs/bagedate.log
+#log4j.appender.bagedate.MaxFileSize=10MB
+#log4j.appender.bagedate.MaxBackupIndex=3
+#log4j.appender.bagedate.layout=org.apache.log4j.PatternLayout
+#log4j.appender.bagedate.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %F %p %m%n