Skip to content

Commit 90a7755

Browse files
committed
fix
1 parent 1eeea8a commit 90a7755

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@
1919

2020
package com.dtstack.flink.sql.launcher;
2121

22-
//import com.aiweiergou.tool.logger.api.ChangeLogLevelProcess;
23-
2422
import com.dtstack.flink.sql.constrant.ConfigConstrant;
2523
import com.google.common.collect.Lists;
2624
import com.alibaba.fastjson.JSON;
@@ -50,7 +48,6 @@
5048
import java.io.IOException;
5149
import java.io.InputStreamReader;
5250
import java.net.URLDecoder;
53-
import java.nio.charset.StandardCharsets;
5451
import java.util.LinkedList;
5552
import java.util.List;
5653
import java.util.Map;
@@ -129,7 +126,7 @@ private static String[] parseJson(String[] args) {
129126
StringBuilder lastStr = new StringBuilder();
130127
try {
131128
FileInputStream fileInputStream = new FileInputStream(args[0]);
132-
InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, StandardCharsets.UTF_8);
129+
InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, Charsets.UTF_8);
133130
reader = new BufferedReader(inputStreamReader);
134131
String tempString;
135132
while ((tempString = reader.readLine()) != null) {

launcher/src/main/java/com/dtstack/flink/sql/launcher/perjob/PerJobSubmitter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ public static String submit(Options launcherOptions, JobGraph jobGraph, Configur
7575
String flinkJobId = jobGraph.getJobID().toString();
7676

7777
String tips = String.format("deploy per_job with appId: %s, jobId: %s", applicationId, flinkJobId);
78-
System.out.println(tips);
7978
LOG.info(tips);
8079

8180
return applicationId;

0 commit comments

Comments
 (0)