This is an automated email from the ASF dual-hosted git repository.
zhouyao2023 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 4d2b55ce3c [Bug][Connector-V2] NoSuchMethodError caused by Netty
version conflict on Spark 3.3.0 (#9632)
4d2b55ce3c is described below
commit 4d2b55ce3c9194218f0fcf5882e0afc5f76421bb
Author: dy102 <[email protected]>
AuthorDate: Tue Jul 29 23:20:04 2025 +0900
[Bug][Connector-V2] NoSuchMethodError caused by Netty version conflict on
Spark 3.3.0 (#9632)
---
.../connector-maxcompute/pom.xml | 34 ++++++++++++++++++++++
.../e2e/connector/maxcompute/MaxComputeIT.java | 17 -----------
2 files changed, 34 insertions(+), 17 deletions(-)
diff --git a/seatunnel-connectors-v2/connector-maxcompute/pom.xml
b/seatunnel-connectors-v2/connector-maxcompute/pom.xml
index 3c4261f930..f85c47fc3f 100644
--- a/seatunnel-connectors-v2/connector-maxcompute/pom.xml
+++ b/seatunnel-connectors-v2/connector-maxcompute/pom.xml
@@ -58,4 +58,38 @@
</dependency>
</dependencies>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <phase>package</phase>
+ <configuration>
+ <relocations>
+ <relocation>
+ <pattern>io.netty</pattern>
+
<shadedPattern>${seatunnel.shade.package}.maxcompute.io.netty</shadedPattern>
+ </relocation>
+ </relocations>
+ <filters>
+ <filter>
+ <artifact>*:*</artifact>
+ <excludes>
+ <exclude>META-INF/*.SF</exclude>
+ <exclude>META-INF/*.DSA</exclude>
+ <exclude>META-INF/*.RSA</exclude>
+ </excludes>
+ </filter>
+ </filters>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
</project>
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-maxcompute-e2e/src/test/java/org/apache/seatunnel/e2e/connector/maxcompute/MaxComputeIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-maxcompute-e2e/src/test/java/org/apache/seatunnel/e2e/connector/maxcompute/MaxComputeIT.java
index 5efe692954..d74ff81a0b 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-maxcompute-e2e/src/test/java/org/apache/seatunnel/e2e/connector/maxcompute/MaxComputeIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-maxcompute-e2e/src/test/java/org/apache/seatunnel/e2e/connector/maxcompute/MaxComputeIT.java
@@ -28,7 +28,6 @@ import
org.apache.seatunnel.connectors.seatunnel.maxcompute.source.MaxcomputeSou
import org.apache.seatunnel.e2e.common.TestResource;
import org.apache.seatunnel.e2e.common.TestSuiteBase;
import org.apache.seatunnel.e2e.common.container.TestContainer;
-import org.apache.seatunnel.e2e.common.container.spark.Spark3Container;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.AfterAll;
@@ -196,10 +195,6 @@ public class MaxComputeIT extends TestSuiteBase implements
TestResource {
@TestTemplate
public void testMaxCompute(TestContainer container)
throws IOException, InterruptedException, OdpsException {
- if (container instanceof Spark3Container) {
- log.info("Skip on Spark 3.3.0 due to Netty conflict.");
- return;
- }
Odps odps = getTestOdps();
odps.tables().delete("mocked_mc", "test_table_sink", true);
createEmptyTable(odps, "test_table_sink");
@@ -223,10 +218,6 @@ public class MaxComputeIT extends TestSuiteBase implements
TestResource {
@TestTemplate
public void testMaxComputeMultiTable(TestContainer container)
throws OdpsException, IOException, InterruptedException {
- if (container instanceof Spark3Container) {
- log.info("Skip on Spark 3.3.0 due to Netty conflict.");
- return;
- }
Odps odps = getTestOdps();
odps.tables().delete("mocked_mc", "test_table_sink", true);
odps.tables().delete("mocked_mc", "test_table_2_sink", true);
@@ -265,10 +256,6 @@ public class MaxComputeIT extends TestSuiteBase implements
TestResource {
@TestTemplate
public void testMaxComputeUpsert(TestContainer container)
throws IOException, InterruptedException, OdpsException {
- if (container instanceof Spark3Container) {
- log.info("Skip on Spark 3.3.0 due to Netty conflict.");
- return;
- }
Odps odps = getTestOdps();
odps.tables().delete("mocked_mc", "test_table_sink", true);
createTableWithData(odps, "test_table_sink");
@@ -298,10 +285,6 @@ public class MaxComputeIT extends TestSuiteBase implements
TestResource {
@TestTemplate
public void testMaxComputeDelete(TestContainer container)
throws IOException, InterruptedException, OdpsException {
- if (container instanceof Spark3Container) {
- log.info("Skip on Spark 3.3.0 due to Netty conflict.");
- return;
- }
Odps odps = getTestOdps();
odps.tables().delete("mocked_mc", "test_table_sink", true);
createTableWithData(odps, "test_table_sink");
