diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceTableConfig.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceTableConfig.java index f0af8513776..a3522e9c146 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceTableConfig.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceTableConfig.java @@ -101,7 +101,9 @@ public static List of(ReadonlyConfig connectorConfig) { if (tableList.size() > 1) { List tableIds = - tableList.stream().map(e -> e.getTablePath()).collect(Collectors.toList()); + tableList.stream() + .map(JdbcSourceTableConfig::getTablePath) + .collect(Collectors.toList()); Set tableIdSet = new HashSet<>(tableIds); if (tableIdSet.size() < tableList.size() - 1) { throw new IllegalArgumentException( diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/AbstractJdbcIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/AbstractJdbcIT.java index 6b574512c76..24b916d4049 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/AbstractJdbcIT.java +++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/AbstractJdbcIT.java @@ -26,6 +26,7 @@ import org.apache.seatunnel.api.table.catalog.PrimaryKey; import org.apache.seatunnel.api.table.catalog.TablePath; import org.apache.seatunnel.api.table.catalog.TableSchema; +import org.apache.seatunnel.api.table.catalog.exception.CatalogException; import org.apache.seatunnel.api.table.catalog.exception.TableNotExistException; import org.apache.seatunnel.api.table.type.SeaTunnelRow; import org.apache.seatunnel.common.exception.SeaTunnelRuntimeException; @@ -463,19 +464,17 @@ public void testCatalog() { catalog.dropDatabase(targetTablePath, false); Assertions.assertFalse(catalog.databaseExists(targetTablePath.getDatabaseName())); } - - TableNotExistException exception = + Exception exception = Assertions.assertThrows( - TableNotExistException.class, + Exception.class, () -> catalog.truncateTable( TablePath.of("not_exist", "not_exist", "not_exist"), false)); - Assertions.assertEquals( - String.format( - "ErrorCode:[API-05], ErrorDescription:[Table not existed] - Table not_exist.not_exist.not_exist does not exist in Catalog %s.", - catalog.name()), - exception.getMessage()); + + Assertions.assertTrue( + exception instanceof TableNotExistException + || exception instanceof CatalogException); } @Test