You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by zh...@apache.org on 2024/04/02 05:36:03 UTC
(seatunnel) branch dev updated: [Improve][CDC] Improve read performance when record not contains schema field (#6571)
This is an automated email from the ASF dual-hosted git repository.
zhouyao2023 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new e60beb28ec [Improve][CDC] Improve read performance when record not contains schema field (#6571)
e60beb28ec is described below
commit e60beb28ecdea41cc3730630f487cd6fa398568c
Author: Jia Fan <fa...@qq.com>
AuthorDate: Tue Apr 2 13:35:58 2024 +0800
[Improve][CDC] Improve read performance when record not contains schema field (#6571)
---
.../apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java
index 872669eacd..abbdb5b76a 100644
--- a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java
+++ b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java
@@ -202,10 +202,8 @@ public class SourceRecordUtils {
String databaseName = sourceStruct.getString(AbstractSourceInfo.DATABASE_NAME_KEY);
String tableName = sourceStruct.getString(AbstractSourceInfo.TABLE_NAME_KEY);
String schemaName = null;
- try {
+ if (sourceStruct.schema().field(AbstractSourceInfo.SCHEMA_NAME_KEY) != null) {
schemaName = sourceStruct.getString(AbstractSourceInfo.SCHEMA_NAME_KEY);
- } catch (Throwable e) {
- // ignore
}
return TablePath.of(databaseName, schemaName, tableName);
}