fixed

sunxiaojian · Aug 11, 2024 · 8a743dc · 8a743dc
1 parent a529c8e
commit 8a743dc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
diff --git a/...b/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBSource.java b/...b/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBSource.java
@@ -17,7 +17,6 @@
 
 package org.apache.seatunnel.connectors.seatunnel.cdc.tidb.source;
 
-import org.apache.seatunnel.api.common.JobContext;
 import org.apache.seatunnel.api.configuration.ReadonlyConfig;
 import org.apache.seatunnel.api.source.Boundedness;
 import org.apache.seatunnel.api.source.SeaTunnelSource;
@@ -39,10 +38,10 @@ public class TiDBSource
                 SupportParallelism,
                 SupportColumnProjection {
 
-    private JobContext jobContext;
+    static final String IDENTIFIER = "TIDB-CDC";
+
     private TiDBSourceConfig config;
     private final CatalogTable catalogTable;
-    static final String IDENTIFIER = "TIDB-CDC";
 
     public TiDBSource(ReadonlyConfig config, CatalogTable catalogTable) {
 
@@ -68,11 +67,6 @@ public String getPluginName() {
         return IDENTIFIER;
     }
 
-    @Override
-    public void setJobContext(JobContext jobContext) {
-        this.jobContext = jobContext;
-    }
-
     /**
      * Get the boundedness of this source.
      *

diff --git a/...va/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java b/...va/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java
@@ -165,7 +165,7 @@ protected void snapshotEvents(TiDBSourceSplit split, Collector<SeaTunnelRow> out
                 }
                 for (final Kvrpcpb.KvPair pair : segment) {
                     if (TableKeyRangeUtils.isRecordKey(pair.getKey().toByteArray())) {
-                        this.snapshotRecordDeserializer.deserialize(pair, output);
+                        snapshotRecordDeserializer.deserialize(pair, output);
                     }
                 }
                 start =