[hotfix-#1449][ClickHouse] fix ClickHouse source null pointer problem (…

…#1450) Co-authored-by: OT-XY <ptsxndg@gmail.com>
DTStack · Dec 20, 2022 · bc190ce · bc190ce
1 parent 6bb1615
commit bc190ce
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/.../src/main/java/com/dtstack/chunjun/connector/clickhouse/source/ClickhouseInputFormat.java b/.../src/main/java/com/dtstack/chunjun/connector/clickhouse/source/ClickhouseInputFormat.java
@@ -36,23 +36,23 @@ public class ClickhouseInputFormat extends JdbcInputFormat {
 
     @Override
     public void openInternal(InputSplit inputSplit) {
-        JdbcInputSplit jdbcInputSplit = (JdbcInputSplit) inputSplit;
-        initMetric(jdbcInputSplit);
-        if (!canReadData(jdbcInputSplit)) {
+        currentJdbcInputSplit = (JdbcInputSplit) inputSplit;
+        initMetric(currentJdbcInputSplit);
+        if (!canReadData(currentJdbcInputSplit)) {
             LOG.warn(
                     "Not read data when the start location are equal to end location, start = {}, end = {}",
-                    jdbcInputSplit.getStartLocation(),
-                    jdbcInputSplit.getEndLocation());
+                    currentJdbcInputSplit.getStartLocation(),
+                    currentJdbcInputSplit.getEndLocation());
             hasNext = false;
             return;
         }
 
         String querySQL = null;
         try {
             dbConn = getConnection();
-            querySQL = buildQuerySql(jdbcInputSplit);
+            querySQL = buildQuerySql(currentJdbcInputSplit);
             jdbcConf.setQuerySql(querySQL);
-            executeQuery(jdbcInputSplit.getStartLocation());
+            executeQuery(currentJdbcInputSplit.getStartLocation());
             // 增量任务
             needUpdateEndLocation =
                     jdbcConf.isIncrement() && !jdbcConf.isPolling() && !jdbcConf.isUseMaxFunc();