You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by yu...@apache.org on 2023/06/06 09:55:36 UTC
[incubator-paimon] branch master updated: [flink][bug] MySqlSyncDatabaseActionITCase doesn't need to handle incompatible table
This is an automated email from the ASF dual-hosted git repository.
yuzelin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new aafe2f07f [flink][bug] MySqlSyncDatabaseActionITCase doesn't need to handle incompatible table
aafe2f07f is described below
commit aafe2f07f89c2a0dcdaa51a2977dba7667ec3437
Author: Alibaba-HZY <da...@cainiao.com>
AuthorDate: Thu Jun 1 10:20:05 2023 +0800
[flink][bug] MySqlSyncDatabaseActionITCase doesn't need to handle incompatible table
---
.../apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java
index ec9cc8f3c..6d7150516 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java
@@ -192,13 +192,14 @@ public class MySqlSyncDatabaseAction extends ActionBase {
incompatibleMessage(table.schema(), mySqlSchema, identifier);
if (shouldMonitorTable(table.schema(), fromMySql, errMsg)) {
monitoredTables.add(mySqlSchema.tableName());
+ fileStoreTables.add(table);
}
} catch (Catalog.TableNotExistException e) {
catalog.createTable(identifier, fromMySql, false);
table = (FileStoreTable) catalog.getTable(identifier);
monitoredTables.add(mySqlSchema.tableName());
+ fileStoreTables.add(table);
}
- fileStoreTables.add(table);
}
Preconditions.checkState(