This is an automated email from the ASF dual-hosted git repository.
JNSimba pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 949a0636989 branch-4.0: [fix](streaming-job) Isolate schemas for CDC
snapshot splits (#66094)
949a0636989 is described below
commit 949a0636989ba92475322fc515665e63e445c2b2
Author: wudi <[email protected]>
AuthorDate: Thu Jul 30 16:02:17 2026 +0800
branch-4.0: [fix](streaming-job) Isolate schemas for CDC snapshot splits
(#66094)
pick https://github.com/apache/doris/pull/65645
---
.../doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java | 2 +-
.../apache/doris/cdcclient/source/reader/mysql/MySqlSourceReader.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java
b/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java
index f4720579051..646cf5b7c6e 100644
---
a/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java
+++
b/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java
@@ -613,7 +613,7 @@ public abstract class JdbcIncrementalSourceReader extends
AbstractCdcSourceReade
splitStart,
splitEnd,
null,
- tableSchemas);
+ Collections.singletonMap(tableId, tableChange));
return split;
}
diff --git
a/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/mysql/MySqlSourceReader.java
b/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/mysql/MySqlSourceReader.java
index 477c0a36f01..c1b6e34a3f8 100644
---
a/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/mysql/MySqlSourceReader.java
+++
b/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/mysql/MySqlSourceReader.java
@@ -610,7 +610,7 @@ public class MySqlSourceReader extends
AbstractCdcSourceReader {
splitStart,
splitEnd,
null,
- tableSchemas);
+ Collections.singletonMap(tableId, tableChange));
return split;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
