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,