diff --git a/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/source/ClickhouseInputFormat.java b/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/source/ClickhouseInputFormat.java
index f41b6d1a40..cc8da2cff2 100644
--- a/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/source/ClickhouseInputFormat.java
+++ b/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/source/ClickhouseInputFormat.java
@@ -36,13 +36,13 @@ 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;
         }
@@ -50,9 +50,9 @@ public void openInternal(InputSplit inputSplit) {
         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();