Merge branch 'feat_logLevel_mergeTest' into '1.8_test_3.10.x'

Feat log level merge test



See merge request !277

Author: dapeng

README.md

@@ -149,6 +149,7 @@ sh submit.sh -sql D:\sideSql.txt  -name xctest -remoteSqlPluginPath /opt/dtstack
         * taskmanager.slots：per_job模式下指定每个taskmanager对应的slot数量(默认1)
         * savePointPath：任务恢复点的路径（默认无）
         * allowNonRestoredState：指示保存点是否允许非还原状态的标志（默认false）
+        * logLevel: 日志级别动态配置（默认info）
         * [prometheus 相关参数](docs/prometheus.md) per_job可指定metric写入到外部监控组件,以prometheus pushgateway举例
 
 
@@ -182,10 +183,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

@@ -63,6 +63,8 @@ public class ConfigConstrant {
     public static final String CHECKPOINTS_DIRECTORY_KEY = "state.checkpoints.dir";
     public static final String STATE_BACKEND_INCREMENTAL_KEY = "state.backend.incremental";
 
+    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()]);