fixed

sunxiaojian · Aug 9, 2024 · 5b386bb · 5b386bb
1 parent 2edba9e
commit 5b386bb
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -32,6 +32,7 @@
 import org.apache.seatunnel.connectors.seatunnel.cdc.tidb.source.config.TiDBSourceOptions;
 import org.apache.seatunnel.connectors.seatunnel.cdc.tidb.source.enumerator.TiDBSourceCheckpointState;
 import org.apache.seatunnel.connectors.seatunnel.cdc.tidb.source.enumerator.TiDBSourceSplitEnumerator;
+import org.apache.seatunnel.connectors.seatunnel.cdc.tidb.source.reader.TiDBSourceReader;
 import org.apache.seatunnel.connectors.seatunnel.cdc.tidb.source.split.TiDBSourceSplit;
 
 import java.util.List;
@@ -98,7 +99,7 @@ public Boundedness getBoundedness() {
     @Override
     public SourceReader<SeaTunnelRow, TiDBSourceSplit> createReader(SourceReader.Context context)
             throws Exception {
-        return null;
+        return new TiDBSourceReader(context, config);
     }
 
     /**