From 8a743dc633e2c7488ee40f5a45a203c6730b5a56 Mon Sep 17 00:00:00 2001 From: sunxiaojian Date: Sun, 11 Aug 2024 18:13:40 +0800 Subject: [PATCH] fixed --- .../seatunnel/cdc/tidb/source/TiDBSource.java | 10 ++-------- .../cdc/tidb/source/reader/TiDBSourceReader.java | 2 +- 2 files changed, 3 insertions(+), 9 deletions(-) diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBSource.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBSource.java index 59efe7b44239..257cbbfe0cec 100644 --- a/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBSource.java +++ b/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/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/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java index c34a50c5ae6b..c2902cef8185 100644 --- a/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java +++ b/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java @@ -165,7 +165,7 @@ protected void snapshotEvents(TiDBSourceSplit split, Collector out } for (final Kvrpcpb.KvPair pair : segment) { if (TableKeyRangeUtils.isRecordKey(pair.getKey().toByteArray())) { - this.snapshotRecordDeserializer.deserialize(pair, output); + snapshotRecordDeserializer.deserialize(pair, output); } } start =