diff --git a/eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/handle/GeneralDialectAssemblyLine.java b/eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/handle/GeneralDialectAssemblyLine.java index b35db15abf..98c94b41f5 100644 --- a/eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/handle/GeneralDialectAssemblyLine.java +++ b/eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/handle/GeneralDialectAssemblyLine.java @@ -281,7 +281,7 @@ private void addColumnDefaultValue(Column column, StringBuilder builder) { private String assembleDropTableSql(CatalogChanges catalogChanges) { SqlStatementAssembler assembler = new SqlStatementAssembler(); assembler.appendSqlSlice("DROP TABLE IF EXISTS "); - assembler.appendSqlSlice( + assembler.appendSqlSlice( ((AbstractGeneralDatabaseDialect) databaseDialect).getQualifiedTableName(catalogChanges.getTable().getTableId())); return assembler.build(); }