We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ac7bc46 commit 425bdc2Copy full SHA for 425bdc2
core/src/main/java/com/dtstack/flink/sql/Main.java
@@ -38,7 +38,6 @@ public class Main {
38
39
public static void main(String[] args) throws Exception {
40
ParamsInfo paramsInfo = ExecuteProcessHelper.parseParams(args);
41
- ExecuteProcessHelper.setLogLevel(paramsInfo);
42
StreamExecutionEnvironment env = ExecuteProcessHelper.getStreamExecution(paramsInfo);
43
env.execute(paramsInfo.getName());
44
LOG.info("program {} execution success", paramsInfo.getName());
0 commit comments