Merge branch 'feat_logLevel_mergeDev' into 'v1.8.0_dev'

Feat log level merge dev



See merge request !275

Author: zoudaokoulife

README.md

@@ -152,6 +152,7 @@ sh submit.sh -sql D:\sideSql.txt  -name xctest -remoteSqlPluginPath /opt/dtstack
         * restore.enable：是否失败重启（默认是true）
         * failure.interval：衡量失败率的时间段，单位分钟（默认6m）
         * delay.interval：连续两次重启尝试间的间隔，单位是秒（默认10s）
+    	* logLevel: 日志级别动态配置（默认info）
         * [prometheus 相关参数](docs/prometheus.md) per_job可指定metric写入到外部监控组件,以prometheus pushgateway举例
 
 
@@ -185,10 +186,6 @@ sh submit.sh -sql D:\sideSql.txt  -name xctest -remoteSqlPluginPath /opt/dtstack
 	* 必选：否
 	* 默认值：false	
 
-* **logLevel**
-    	* 描述：设定日志级别
-    	* 必选：否
-    	* 默认值：info	
 
 ## 2 结构
 ### 2.1 源表插件

core/src/main/java/com/dtstack/flink/sql/constrant/ConfigConstrant.java

@@ -65,6 +65,8 @@ public class ConfigConstrant {
 
     public static final String RESTOREENABLE = "restore.enable";
 
+        public static final String LOG_LEVEL_KEY = "logLevel";
+
 
     // restart plocy
     public static final int failureRate = 3;

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

@@ -84,7 +84,7 @@ public static void main(String[] args) throws Exception {
         confProp = URLDecoder.decode(confProp, Charsets.UTF_8.toString());
         Properties confProperties = PluginUtil.jsonStrToObject(confProp, Properties.class);
 
-        setLogLevel(launcherOptions.getLogLevel());
+        setLogLevel(confProperties.getProperty(ConfigConstrant.LOG_LEVEL_KEY));
 
         if(mode.equals(ClusterMode.local.name())) {
             String[] localArgs = argList.toArray(new String[argList.size()]);