Skip to content

Commit a3dc6c6

Browse files
committed
[移除SYSTEM输出]
1 parent 282b4d0 commit a3dc6c6

File tree

5 files changed

+0
-6
lines changed

5 files changed

+0
-6
lines changed

cassandra/cassandra-side/cassandra-all-side/src/main/java/com/dtstack/flink/sql/side/cassandra/CassandraAllSideInfo.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
5454
sqlCondition = "select ${selectField} from ${tableName} ";
5555
sqlCondition = sqlCondition.replace("${tableName}", cassandraSideTableInfo.getDatabase() + "."
5656
+ cassandraSideTableInfo.getTableName()).replace("${selectField}", sideSelectFields);
57-
System.out.println("---------side_exe_sql-----\n" + sqlCondition);
5857
}
5958

6059
@Override

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,6 @@ public static void main(String[] args) throws Exception {
100100
clusterClient.shutdown();
101101
}
102102

103-
System.out.println("---submit end----");
104103
}
105104

106105
private static String[] parseJson(String[] args) {

oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle/OracleSink.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,8 +71,6 @@ private void buildInsertSql(String tableName, List<String> fields) {
7171
placeholder = placeholder.replaceFirst(",", "");
7272
sqlTmp = sqlTmp.replace("${fields}", fieldsStr).replace("${placeholder}", placeholder);
7373
this.sql = sqlTmp;
74-
System.out.println("--------insert sqlTmp--------");
75-
System.out.println(sql);
7674
}
7775

7876
@Override

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/RdbAllSideInfo.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
5656

5757
sqlCondition = "select ${selectField} from ${tableName} ";
5858
sqlCondition = sqlCondition.replace("${tableName}", rdbSideTableInfo.getTableName()).replace("${selectField}", sideSelectFields);
59-
System.out.println("---------side_exe_sql-----\n" + sqlCondition);
6059
}
6160

6261
@Override

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncSideInfo.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
7979
}
8080

8181
sqlCondition = sqlCondition.replace("${tableName}", rdbSideTableInfo.getTableName()).replace("${selectField}", sideSelectFields);
82-
System.out.println("---------side_exe_sql-----\n" + sqlCondition);
8382
}
8483

8584

0 commit comments

Comments
 (0)