Skip to content

Commit 6aef060

Browse files
committed
fix
1 parent 6bee2d9 commit 6aef060

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,8 +84,6 @@ public abstract class JdbcIncrementalSourceReader implements SourceReader {
8484
private static final Logger LOG = LoggerFactory.getLogger(JdbcIncrementalSourceReader.class);
8585
private static ObjectMapper objectMapper = new ObjectMapper();
8686
private SourceRecordDeserializer<SourceRecord, List<String>> serializer;
87-
// private IncrementalSourceScanFetcher snapshotReader;
88-
// private IncrementalSourceStreamFetcher binlogReader;
8987
private Fetcher<SourceRecords, SourceSplitBase> currentReader;
9088
private Map<TableId, TableChanges.TableChange> tableSchemas;
9189
private SplitRecords currentSplitRecords;

0 commit comments

Comments
 (0)