This is an automated email from the ASF dual-hosted git repository.

yzeng1618 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new eb7ad63a12 [Fix][Connector-V2] Adapt JdbcHiveIT to JdbcCatalogUtils 
getTables signature (#10998)
eb7ad63a12 is described below

commit eb7ad63a12d2e676f86066d34564b53907b92498
Author: yzeng1618 <[email protected]>
AuthorDate: Wed Jun 3 09:16:47 2026 +0800

    [Fix][Connector-V2] Adapt JdbcHiveIT to JdbcCatalogUtils getTables 
signature (#10998)
    
    Co-authored-by: zengyi <[email protected]>
---
 .../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
index 9fb14c8f9a..4cb9390d21 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
@@ -20,6 +20,7 @@ package org.apache.seatunnel.connectors.seatunnel.jdbc;
 import org.apache.seatunnel.shade.com.google.common.collect.Lists;
 import org.apache.seatunnel.shade.org.apache.commons.lang3.tuple.Pair;
 
+import org.apache.seatunnel.api.options.MultiTableFailurePolicy;
 import org.apache.seatunnel.api.table.catalog.TablePath;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.common.exception.SeaTunnelRuntimeException;
@@ -231,7 +232,8 @@ public class JdbcHiveIT extends AbstractJdbcIT {
                                     .username(jdbcCase.getUserName())
                                     .password(jdbcCase.getPassword())
                                     .build(),
-                            Lists.newArrayList(tableConfig));
+                            Lists.newArrayList(tableConfig),
+                            MultiTableFailurePolicy.FAIL_FAST);
             JdbcSourceTable partitionSourceTable = 
tables.get(partitionTablePath);
             Assertions.assertNotNull(
                     partitionSourceTable,

Reply via email to