This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new fe88af97 [Fix] Fix the problem that the existing tables in Doris
cannot be synchronized.(#425)
fe88af97 is described below
commit fe88af97a54a9bc792a4291fb80a95f5fe15e38b
Author: Petrichor <[email protected]>
AuthorDate: Mon Jul 15 10:04:50 2024 +0800
[Fix] Fix the problem that the existing tables in Doris cannot be
synchronized.(#425)
---
.../java/org/apache/doris/flink/tools/cdc/DatabaseSync.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
index a4d0511b..5cea70f9 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
@@ -152,13 +152,15 @@ public abstract class DatabaseSync {
// Calculate the mapping relationship between upstream and
downstream tables
tableMapping.put(
schema.getTableIdentifier(), String.format("%s.%s",
targetDb, dorisTable));
- if (tryCreateTableIfAbsent(
+ tryCreateTableIfAbsent(
dorisSystem,
targetDb,
dorisTable,
schema,
tableBucketsMap,
- tablesWithBucketsAssigned)) {
+ tablesWithBucketsAssigned);
+
+ if (!dorisTables.contains(Tuple2.of(targetDb, dorisTable))) {
dorisTables.add(Tuple2.of(targetDb, dorisTable));
}
}
@@ -463,7 +465,7 @@ public abstract class DatabaseSync {
}
}
- private boolean tryCreateTableIfAbsent(
+ private void tryCreateTableIfAbsent(
DorisSystem dorisSystem,
String targetDb,
String dorisTable,
@@ -480,12 +482,10 @@ public abstract class DatabaseSync {
}
try {
dorisSystem.createTable(dorisSchema);
- return true;
} catch (Exception ex) {
handleTableCreationFailure(ex);
}
}
- return false;
}
private void handleTableCreationFailure(Exception ex) throws
DorisSystemException {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
