[Fix][Connector-V2] update

apache · Aug 28, 2024 · 94c9bd3 · 94c9bd3
1 parent f833da7
commit 94c9bd3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/...e-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/AbstractJdbcIT.java b/...e-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/AbstractJdbcIT.java
@@ -57,7 +57,6 @@
 import org.testcontainers.lifecycle.Startables;
 
 import com.github.dockerjava.api.model.Image;
-import lombok.SneakyThrows;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -461,9 +460,8 @@ public void testCatalog() {
         }
     }
 
-    @SneakyThrows
     @Test
-    public void testCatalogWithCatalogUtils() {
+    public void testCatalogWithCatalogUtils() throws SQLException, ClassNotFoundException {
         if (StringUtils.isBlank(jdbcCase.getTablePathFullName())) {
             return;
         }
@@ -479,6 +477,7 @@ public void testCatalogWithCatalogUtils() {
                 JdbcCatalogUtils.getTables(
                         JdbcConnectionConfig.builder()
                                 .url(jdbcCase.getJdbcUrl().replace(HOST, dbServer.getHost()))
+                                .driverName(jdbcCase.getDriverClass())
                                 .username(jdbcCase.getUserName())
                                 .password(jdbcCase.getPassword())
                                 .build(),

diff --git a/...c-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java b/...c-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
@@ -44,7 +44,7 @@ public class JdbcHiveIT extends AbstractJdbcIT {
 
     private static final String HIVE_DATABASE = "default";
 
-    private static final String HIVE_SOURCE = "hive_e2e_table_source";
+    private static final String HIVE_SOURCE = "hive_e2e_source_table";
     private static final String HIVE_USERNAME = "root";
     private static final String HIVE_PASSWORD = null;
     private static final int HIVE_PORT = 10000;