File tree Expand file tree Collapse file tree 2 files changed +0
-15
lines changed
src/main/java/com/dtstack/flink/sql/exec Expand file tree Collapse file tree 2 files changed +0
-15
lines changed Original file line number Diff line number Diff line change 122122 <artifactId >junit</artifactId >
123123 <version >4.12</version >
124124 </dependency >
125- <dependency >
126- <groupId >com.aiweiergou</groupId >
127- <artifactId >tools-logger</artifactId >
128- <version >${logger.tool.version} </version >
129- </dependency >
130125 </dependencies >
131126
132127 <build >
Original file line number Diff line number Diff line change 1818
1919package com .dtstack .flink .sql .exec ;
2020
21- import com .aiweiergou .tool .logger .api .ChangeLogLevelProcess ;
2221import com .dtstack .flink .sql .parser .CreateFuncParser ;
2322import com .dtstack .flink .sql .parser .CreateTmpTableParser ;
2423import com .dtstack .flink .sql .parser .FlinkPlanner ;
@@ -354,13 +353,4 @@ public static StreamExecutionEnvironment getStreamExeEnv(Properties confProperti
354353 return env ;
355354 }
356355
357-
358- public static void setLogLevel (ParamsInfo paramsInfo ){
359- String logLevel = paramsInfo .getConfProp ().getProperty (ConfigConstrant .LOG_LEVEL_KEY );
360- if (org .apache .commons .lang3 .StringUtils .isBlank (logLevel )){
361- return ;
362- }
363- ChangeLogLevelProcess logLevelProcess = new ChangeLogLevelProcess ();
364- logLevelProcess .process (logLevel );
365- }
366356}
You can’t perform that action at this time.
0 commit comments