This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new c81b2ffab [Improve][Transform-V2][SQL] Improve stability of
transform-v2-e2e (#4298)
c81b2ffab is described below
commit c81b2ffab1a07cb602a338315d563e04bafb92c7
Author: Tyrantlucifer <[email protected]>
AuthorDate: Wed Mar 8 22:37:24 2023 +0800
[Improve][Transform-V2][SQL] Improve stability of transform-v2-e2e (#4298)
* [Improve][Transform-V2][SQL] Improve stability of transform-v2-e2e
* [Improve][Transform-V2][E2E] Merge cases
* [Improve][Transform-V2][E2E] Split cases
* [Improve][CI] Reduce timeout
* [Improve][CI] Add retry steps
* [Improve][CI] Increase timeout
---
.github/workflows/backend.yml | 44 +++++++++--
seatunnel-e2e/seatunnel-transforms-v2-e2e/pom.xml | 6 ++
.../seatunnel-transforms-v2-e2e-common/pom.xml | 49 +++++++++++++
.../seatunnel/e2e/transform/TestSuiteBase.java | 0
.../seatunnel-transforms-v2-e2e-part-1/pom.xml | 41 +++++++++++
.../apache/seatunnel/e2e/transform/TestCopyIT.java | 0
.../seatunnel/e2e/transform/TestFilterIT.java | 0
.../e2e/transform/TestFilterRowKindIT.java | 24 ++----
.../seatunnel/e2e/transform/TestSplitIT.java | 0
.../src/test/resources/copy_transform.conf | 0
.../resources/filter_row_kind_exclude_delete.conf | 0
.../resources/filter_row_kind_exclude_insert.conf | 0
.../resources/filter_row_kind_include_insert.conf | 0
.../src/test/resources/filter_transform.conf | 0
.../src/test/resources/split_transform.conf | 0
.../seatunnel-transforms-v2-e2e-part-2/pom.xml | 41 +++++++++++
.../seatunnel/e2e/transform/TestFieldMapperIT.java | 0
.../seatunnel/e2e/transform/TestReplaceIT.java | 0
.../apache/seatunnel/e2e/transform/TestSQLIT.java | 59 +++++++++++++++
.../src/test/resources/field_mapper_transform.conf | 0
.../src/test/resources/replace_transform.conf | 0
.../src/test/resources/sql_transform.conf | 0
.../resources/sql_transform/binary_expression.conf | 0
.../resources/sql_transform/criteria_filter.conf | 0
.../resources/sql_transform/func_datetime.conf | 0
.../test/resources/sql_transform/func_numeric.conf | 0
.../test/resources/sql_transform/func_string.conf | 0
.../test/resources/sql_transform/func_system.conf | 0
.../apache/seatunnel/e2e/transform/TestSQLIT.java | 85 ----------------------
29 files changed, 242 insertions(+), 107 deletions(-)
diff --git a/.github/workflows/backend.yml b/.github/workflows/backend.yml
index 534c30c07..11031398e 100644
--- a/.github/workflows/backend.yml
+++ b/.github/workflows/backend.yml
@@ -283,7 +283,7 @@ jobs:
matrix:
java: [ '8', '11' ]
os: [ 'ubuntu-latest', 'windows-latest' ]
- timeout-minutes: 90
+ timeout-minutes: 30
steps:
- uses: actions/checkout@v2
- name: Set up JDK ${{ matrix.java }}
@@ -338,7 +338,7 @@ jobs:
matrix:
java: [ '8', '11' ]
os: [ 'ubuntu-latest' ]
- timeout-minutes: 90
+ timeout-minutes: 30
steps:
- uses: actions/checkout@v2
- name: Set up JDK ${{ matrix.java }}
@@ -354,7 +354,7 @@ jobs:
env:
MAVEN_OPTS: -Xmx4096m
- transform-v2-it:
+ transform-v2-it-part-1:
needs: [ changes, sanity-check ]
if: needs.changes.outputs.api == 'true'
runs-on: ${{ matrix.os }}
@@ -373,8 +373,42 @@ jobs:
cache: 'maven'
- name: run some modules integration test
if: needs.changes.outputs.api == 'true'
- run: |
- ./mvnw -T 1C -B verify -DskipUT=true -DskipIT=false
-D"license.skipAddThirdParty"=true --no-snapshot-updates -pl
:seatunnel-transforms-v2-e2e -am -Pci
+ uses: nick-fields/retry@v2
+ with:
+ timeout_minutes: 30
+ max_attempts: 3
+ continue_on_error: true
+ command: |
+ ./mvnw -T 1C -B verify -DskipUT=true -DskipIT=false
-D"license.skipAddThirdParty"=true --no-snapshot-updates -pl
:seatunnel-transforms-v2-e2e-part-1 -am -Pci
+ env:
+ MAVEN_OPTS: -Xmx4096m
+
+ transform-v2-it-part-2:
+ needs: [ changes, sanity-check ]
+ if: needs.changes.outputs.api == 'true'
+ runs-on: ${{ matrix.os }}
+ strategy:
+ matrix:
+ java: [ '8', '11' ]
+ os: [ 'ubuntu-latest' ]
+ timeout-minutes: 90
+ steps:
+ - uses: actions/checkout@v2
+ - name: Set up JDK ${{ matrix.java }}
+ uses: actions/setup-java@v3
+ with:
+ java-version: ${{ matrix.java }}
+ distribution: 'temurin'
+ cache: 'maven'
+ - name: run some modules integration test
+ if: needs.changes.outputs.api == 'true'
+ uses: nick-fields/retry@v2
+ with:
+ timeout_minutes: 30
+ max_attempts: 3
+ continue_on_error: true
+ command: |
+ ./mvnw -T 1C -B verify -DskipUT=true -DskipIT=false
-D"license.skipAddThirdParty"=true --no-snapshot-updates -pl
:seatunnel-transforms-v2-e2e-part-2 -am -Pci
env:
MAVEN_OPTS: -Xmx4096m
diff --git a/seatunnel-e2e/seatunnel-transforms-v2-e2e/pom.xml
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/pom.xml
index b5474d392..1106fed94 100644
--- a/seatunnel-e2e/seatunnel-transforms-v2-e2e/pom.xml
+++ b/seatunnel-e2e/seatunnel-transforms-v2-e2e/pom.xml
@@ -23,7 +23,13 @@
</parent>
<artifactId>seatunnel-transforms-v2-e2e</artifactId>
+ <packaging>pom</packaging>
<name>SeaTunnel : E2E : Transforms V2</name>
+ <modules>
+ <module>seatunnel-transforms-v2-e2e-common</module>
+ <module>seatunnel-transforms-v2-e2e-part-1</module>
+ <module>seatunnel-transforms-v2-e2e-part-2</module>
+ </modules>
<dependencies>
<dependency>
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-common/pom.xml
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-common/pom.xml
new file mode 100644
index 000000000..4efdc5fad
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-common/pom.xml
@@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+ http://www.apache.org/licenses/LICENSE-2.0
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-transforms-v2-e2e</artifactId>
+ <version>${revision}</version>
+ </parent>
+
+ <artifactId>seatunnel-transforms-v2-e2e-common</artifactId>
+
+ <name>SeaTunnel : E2E : Transforms V2 : Common</name>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-jar-plugin</artifactId>
+ <version>${maven-jar-plugin.version}</version>
+ <configuration>
+ <skip>false</skip>
+ </configuration>
+ <executions>
+ <execution>
+ <goals>
+ <goal>test-jar</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+
+</project>
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSuiteBase.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-common/src/test/java/org/apache/seatunnel/e2e/transform/TestSuiteBase.java
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSuiteBase.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-common/src/test/java/org/apache/seatunnel/e2e/transform/TestSuiteBase.java
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/pom.xml
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/pom.xml
new file mode 100644
index 000000000..1ec74bbde
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/pom.xml
@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+ http://www.apache.org/licenses/LICENSE-2.0
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-transforms-v2-e2e</artifactId>
+ <version>${revision}</version>
+ </parent>
+
+ <artifactId>seatunnel-transforms-v2-e2e-part-1</artifactId>
+
+ <name>SeaTunnel : E2E : Transforms V2 : Part 1</name>
+
+ <dependencies>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-transforms-v2-e2e-common</artifactId>
+ <version>${project.version}</version>
+ <type>test-jar</type>
+ <scope>test</scope>
+ </dependency>
+
+ </dependencies>
+
+</project>
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestCopyIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestCopyIT.java
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestCopyIT.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestCopyIT.java
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterIT.java
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterIT.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterIT.java
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterRowKindIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterRowKindIT.java
similarity index 67%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterRowKindIT.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterRowKindIT.java
index 31e56cfd1..1bb98ef57 100644
---
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterRowKindIT.java
+++
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestFilterRowKindIT.java
@@ -28,26 +28,16 @@ import java.io.IOException;
public class TestFilterRowKindIT extends TestSuiteBase {
@TestTemplate
- public void testFilterRowKindExcludeDelete(TestContainer container)
+ public void testFilterRowKind(TestContainer container)
throws IOException, InterruptedException {
- Container.ExecResult execResult =
+ Container.ExecResult execResult1 =
container.executeJob("/filter_row_kind_exclude_delete.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testFilterRowKindExcludeInsert(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
+ Assertions.assertEquals(0, execResult1.getExitCode());
+ Container.ExecResult execResult2 =
container.executeJob("/filter_row_kind_exclude_insert.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testFilterRowKindIncludeInsert(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
+ Assertions.assertEquals(0, execResult2.getExitCode());
+ Container.ExecResult execResult3 =
container.executeJob("/filter_row_kind_include_insert.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
+ Assertions.assertEquals(0, execResult3.getExitCode());
}
}
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSplitIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestSplitIT.java
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSplitIT.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/java/org/apache/seatunnel/e2e/transform/TestSplitIT.java
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/copy_transform.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/copy_transform.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/copy_transform.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/copy_transform.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_row_kind_exclude_delete.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_row_kind_exclude_delete.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_row_kind_exclude_delete.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_row_kind_exclude_delete.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_row_kind_exclude_insert.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_row_kind_exclude_insert.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_row_kind_exclude_insert.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_row_kind_exclude_insert.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_row_kind_include_insert.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_row_kind_include_insert.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_row_kind_include_insert.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_row_kind_include_insert.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_transform.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_transform.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/filter_transform.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/filter_transform.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/split_transform.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/split_transform.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/split_transform.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-1/src/test/resources/split_transform.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/pom.xml
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/pom.xml
new file mode 100644
index 000000000..9f8df61fb
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/pom.xml
@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+ http://www.apache.org/licenses/LICENSE-2.0
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-transforms-v2-e2e</artifactId>
+ <version>${revision}</version>
+ </parent>
+
+ <artifactId>seatunnel-transforms-v2-e2e-part-2</artifactId>
+
+ <name>SeaTunnel : E2E : Transforms V2 : Part 2</name>
+
+ <dependencies>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-transforms-v2-e2e-common</artifactId>
+ <version>${project.version}</version>
+ <type>test-jar</type>
+ <scope>test</scope>
+ </dependency>
+
+ </dependencies>
+
+</project>
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFieldMapperIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestFieldMapperIT.java
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestFieldMapperIT.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestFieldMapperIT.java
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestReplaceIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestReplaceIT.java
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestReplaceIT.java
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestReplaceIT.java
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestSQLIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestSQLIT.java
new file mode 100644
index 000000000..c12867ad4
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestSQLIT.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.seatunnel.e2e.transform;
+
+import org.apache.seatunnel.e2e.common.container.EngineType;
+import org.apache.seatunnel.e2e.common.container.TestContainer;
+import org.apache.seatunnel.e2e.common.junit.DisabledOnContainer;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.TestTemplate;
+import org.testcontainers.containers.Container;
+
+import java.io.IOException;
+
+@DisabledOnContainer(
+ value = {},
+ type = {EngineType.SPARK},
+ disabledReason = "Some problems of Spark Timestamp type convert
unresolved")
+public class TestSQLIT extends TestSuiteBase {
+
+ @TestTemplate
+ public void testSQLTransform(TestContainer container) throws IOException,
InterruptedException {
+ Container.ExecResult sqlTransform =
container.executeJob("/sql_transform.conf");
+ Assertions.assertEquals(0, sqlTransform.getExitCode());
+ Container.ExecResult sqlBinaryExpression =
+ container.executeJob("/sql_transform/binary_expression.conf");
+ Assertions.assertEquals(0, sqlBinaryExpression.getExitCode());
+ Container.ExecResult sqlFuncString =
+ container.executeJob("/sql_transform/func_string.conf");
+ Assertions.assertEquals(0, sqlFuncString.getExitCode());
+ Container.ExecResult sqlFuncNumeric =
+ container.executeJob("/sql_transform/func_numeric.conf");
+ Assertions.assertEquals(0, sqlFuncNumeric.getExitCode());
+ Container.ExecResult sqlFuncDatetime =
+ container.executeJob("/sql_transform/func_datetime.conf");
+ Assertions.assertEquals(0, sqlFuncDatetime.getExitCode());
+ Container.ExecResult sqlFuncSystem =
+ container.executeJob("/sql_transform/func_system.conf");
+ Assertions.assertEquals(0, sqlFuncSystem.getExitCode());
+ Container.ExecResult sqlCriteriaFilter =
+ container.executeJob("/sql_transform/criteria_filter.conf");
+ Assertions.assertEquals(0, sqlCriteriaFilter.getExitCode());
+ }
+}
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/field_mapper_transform.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/field_mapper_transform.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/field_mapper_transform.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/field_mapper_transform.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/replace_transform.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/replace_transform.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/replace_transform.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/replace_transform.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/binary_expression.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/binary_expression.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/binary_expression.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/binary_expression.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/criteria_filter.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/criteria_filter.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/criteria_filter.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/criteria_filter.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_datetime.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_datetime.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_datetime.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_datetime.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_numeric.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_numeric.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_numeric.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_numeric.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_string.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_string.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_string.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_string.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_system.conf
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_system.conf
similarity index 100%
rename from
seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/resources/sql_transform/func_system.conf
rename to
seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_system.conf
diff --git
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSQLIT.java
b/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSQLIT.java
deleted file mode 100644
index 7b3a6c0c7..000000000
---
a/seatunnel-e2e/seatunnel-transforms-v2-e2e/src/test/java/org/apache/seatunnel/e2e/transform/TestSQLIT.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.seatunnel.e2e.transform;
-
-import org.apache.seatunnel.e2e.common.container.EngineType;
-import org.apache.seatunnel.e2e.common.container.TestContainer;
-import org.apache.seatunnel.e2e.common.junit.DisabledOnContainer;
-
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.TestTemplate;
-import org.testcontainers.containers.Container;
-
-import java.io.IOException;
-
-@DisabledOnContainer(
- value = {},
- type = {EngineType.SPARK},
- disabledReason = "Some problems of Spark Timestamp type convert
unresolved")
-public class TestSQLIT extends TestSuiteBase {
-
- @TestTemplate
- public void testSQLTransform(TestContainer container) throws IOException,
InterruptedException {
- Container.ExecResult execResult =
container.executeJob("/sql_transform.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testSQLTransBinaryExpr(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
- container.executeJob("/sql_transform/binary_expression.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testSQLTransStringFunction(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
container.executeJob("/sql_transform/func_string.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testSQLTransNumericFunction(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
container.executeJob("/sql_transform/func_numeric.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testSQLTransDatetimeFunction(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
container.executeJob("/sql_transform/func_datetime.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testSQLTransSystemFunction(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
container.executeJob("/sql_transform/func_system.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-
- @TestTemplate
- public void testSQLTransCriteriaFilter(TestContainer container)
- throws IOException, InterruptedException {
- Container.ExecResult execResult =
- container.executeJob("/sql_transform/criteria_filter.conf");
- Assertions.assertEquals(0, execResult.getExitCode());
- }
-}
