This is an automated email from the ASF dual-hosted git repository.
fanjia 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 5c79e8e17 [Improve][Connector-V2][Http] Add e2e testcase (#3340)
5c79e8e17 is described below
commit 5c79e8e17ac5a2bc88c311ab7af58ef761c805be
Author: hailin0 <[email protected]>
AuthorDate: Wed Nov 9 16:24:21 2022 +0800
[Improve][Connector-V2][Http] Add e2e testcase (#3340)
---
.../{ => connector-http-e2e}/pom.xml | 25 +-
.../seatunnel/e2e/connector/http/HttpIT.java | 76 +++++
.../src/test/resources/http_json_to_assert.conf | 110 ++++++
.../src/test/resources/mockserver-config.json | 367 +++++++++++++++++++++
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
5 files changed, 560 insertions(+), 19 deletions(-)
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/pom.xml
similarity index 68%
copy from seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
copy to seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/pom.xml
index e5d8ca076..9422ad199 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/pom.xml
@@ -17,46 +17,33 @@
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";>
<parent>
- <artifactId>seatunnel-e2e</artifactId>
<groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-v2-e2e</artifactId>
<version>${revision}</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <packaging>pom</packaging>
- <modules>
- <module>connector-assert-e2e</module>
- <module>connector-jdbc-e2e</module>
- <module>connector-redis-e2e</module>
- <module>connector-clickhouse-e2e</module>
- <module>connector-starrocks-e2e</module>
- <module>connector-influxdb-e2e</module>
- <module>connector-amazondynamodb-e2e</module>
- <module>connector-file-local-e2e</module>
- <module>connector-cassandra-e2e</module>
- </modules>
- <artifactId>seatunnel-connector-v2-e2e</artifactId>
+ <artifactId>connector-http-e2e</artifactId>
<dependencies>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-e2e-common</artifactId>
+ <artifactId>connector-assert</artifactId>
<version>${project.version}</version>
- <type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-flink-starter</artifactId>
+ <artifactId>connector-console</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-spark-starter</artifactId>
+ <artifactId>connector-http-base</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
</dependencies>
-</project>
+</project>
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
new file mode 100644
index 000000000..b781a3412
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
@@ -0,0 +1,76 @@
+/*
+ * 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.connector.http;
+
+import org.apache.seatunnel.e2e.common.TestResource;
+import org.apache.seatunnel.e2e.common.TestSuiteBase;
+import org.apache.seatunnel.e2e.common.container.TestContainer;
+
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.TestTemplate;
+import org.testcontainers.containers.Container;
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;
+import org.testcontainers.lifecycle.Startables;
+import org.testcontainers.utility.DockerImageName;
+import org.testcontainers.utility.DockerLoggerFactory;
+import org.testcontainers.utility.MountableFile;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.stream.Stream;
+
+public class HttpIT extends TestSuiteBase implements TestResource {
+
+ private static final String IMAGE = "mockserver/mockserver:5.14.0";
+
+ private GenericContainer<?> mockserverContainer;
+
+ @BeforeAll
+ @Override
+ public void startUp() {
+ this.mockserverContainer = new
GenericContainer<>(DockerImageName.parse(IMAGE))
+ .withNetwork(NETWORK)
+ .withNetworkAliases("mockserver")
+ .withExposedPorts(1080)
+ .withCopyFileToContainer(MountableFile.forHostPath(new
File(HttpIT.class.getResource(
+ "/mockserver-config.json").getPath()).getAbsolutePath()),
+ "/tmp/mockserver-config.json")
+ .withEnv("MOCKSERVER_INITIALIZATION_JSON_PATH",
"/tmp/mockserver-config.json")
+ .withLogConsumer(new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(IMAGE)))
+ .waitingFor(new
HttpWaitStrategy().forPath("/").forStatusCode(404));
+ Startables.deepStart(Stream.of(mockserverContainer)).join();
+ }
+
+ @AfterAll
+ @Override
+ public void tearDown() {
+ if (mockserverContainer != null) {
+ mockserverContainer.stop();
+ }
+ }
+
+ @TestTemplate
+ public void testHttpSourceToAssertSink(TestContainer container) throws
IOException, InterruptedException {
+ Container.ExecResult execResult =
container.executeJob("/http_json_to_assert.conf");
+ Assertions.assertEquals(0, execResult.getExitCode());
+ }
+}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/http_json_to_assert.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/http_json_to_assert.conf
new file mode 100644
index 000000000..0be93df24
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/http_json_to_assert.conf
@@ -0,0 +1,110 @@
+#
+# 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.
+#
+
+env {
+ execution.parallelism = 1
+ job.mode = "BATCH"
+}
+
+source {
+ Http {
+ url = "http://mockserver:1080/example/http";
+ method = "GET"
+ format = "json"
+ schema = {
+ fields {
+ c_map = "map<string, string>"
+ c_array = "array<int>"
+ c_string = string
+ c_boolean = boolean
+ c_tinyint = tinyint
+ c_smallint = smallint
+ c_int = int
+ c_bigint = bigint
+ c_float = float
+ c_double = double
+ c_bytes = bytes
+ c_date = date
+ c_decimal = "decimal(38, 18)"
+ c_timestamp = timestamp
+ c_row = {
+ c_map = "map<string, string>"
+ c_array = "array<int>"
+ c_string = string
+ c_boolean = boolean
+ c_tinyint = tinyint
+ c_smallint = smallint
+ c_int = int
+ c_bigint = bigint
+ c_float = float
+ c_double = double
+ c_bytes = bytes
+ c_date = date
+ c_decimal = "decimal(38, 18)"
+ c_timestamp = timestamp
+ }
+ }
+ }
+ }
+}
+
+sink {
+ Console {}
+ Assert {
+ rules {
+ row_rules = [
+ {
+ rule_type = MAX_ROW
+ rule_value = 5
+ },
+ {
+ rule_type = MIN_ROW
+ rule_value = 5
+ }
+ ],
+ field_rules = [
+ {
+ field_name = c_string
+ field_type = string
+ field_value = [
+ {
+ rule_type = NOT_NULL
+ }
+ ]
+ },
+ {
+ field_name = c_boolean
+ field_type = boolean
+ field_value = [
+ {
+ rule_type = NOT_NULL
+ }
+ ]
+ },
+ {
+ field_name = c_double
+ field_type = double
+ field_value = [
+ {
+ rule_type = NOT_NULL
+ }
+ ]
+ }
+ ]
+ }
+ }
+}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/mockserver-config.json
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/mockserver-config.json
new file mode 100644
index 000000000..6dba61eb0
--- /dev/null
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/resources/mockserver-config.json
@@ -0,0 +1,367 @@
+//
https://www.mock-server.com/mock_server/getting_started.html#request_matchers
+
+[
+ {
+ "httpRequest": {
+ "method" : "GET",
+ "path": "/example/http"
+ },
+ "httpResponse": {
+ "body": [
+ {
+ "c_map":{
+ "ccQcS":"PrhhP",
+ "ypJZu":"MsOdX",
+ "YFBJW":"iPXGR",
+ "ipjwT":"kcgPQ",
+ "EpKKR":"jgRfX"
+ },
+ "c_array":[
+ 887776100,
+ 1633238485,
+ 1009033208,
+ 600614572,
+ 1487972145
+ ],
+ "c_string":"WArEB",
+ "c_boolean":false,
+ "c_tinyint":-90,
+ "c_smallint":15920,
+ "c_int":1127427935,
+ "c_bigint":4712806879122100224,
+ "c_float":162047600000000000000000000000000000000,
+
"c_double":27509088104078520000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "c_bytes":"Q3NrVnQ=",
+ "c_date":"2022-04-27",
+ "c_decimal":88574263949141714798.835853182708550244,
+ "c_timestamp":"2022-01-26T17:39:00",
+ "c_row":{
+ "C_MAP":{
+ "IVaKD":"bydeV",
+ "CnKBd":"kcZdt",
+ "RGlmG":"XuMyE",
+ "krSIr":"FPeal",
+ "IfhvE":"ReKxo"
+ },
+ "C_ARRAY":[
+ 86555282,
+ 967939739,
+ 1162972923,
+ 1662468723,
+ 546056811
+ ],
+ "C_STRING":"bYjyZ",
+ "C_BOOLEAN":false,
+ "C_TINYINT":-121,
+ "C_SMALLINT":29252,
+ "C_INT":977226449,
+ "C_BIGINT":5047232039582494720,
+ "C_FLOAT":253456430000000000000000000000000000000,
+
"C_DOUBLE":158834248299979960000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "C_BYTES":"TEVLTHU=",
+ "C_DATE":"2022-04-25",
+ "C_DECIMAL":55295207715324162970.316560703127334413,
+ "C_TIMESTAMP":"2022-06-14T23:03:00"
+ }
+ },
+ {
+ "c_map":{
+ "AKiQx":"wIIdk",
+ "zgunZ":"qvHRy",
+ "ohVQL":"WfBPo",
+ "EzUcN":"yPhVF",
+ "qusBc":"FWbcI"
+ },
+ "c_array":[
+ 1837821269,
+ 980724530,
+ 2085935679,
+ 386596035,
+ 1433416218
+ ],
+ "c_string":"LGMAw",
+ "c_boolean":false,
+ "c_tinyint":-65,
+ "c_smallint":25802,
+ "c_int":1312064317,
+ "c_bigint":4434124023629949952,
+ "c_float":101861250000000000000000000000000000000,
+
"c_double":30746920457833206000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "c_bytes":"V2pjem4=",
+ "c_date":"2022-04-21",
+ "c_decimal":1943815605574160687.499688237951975681,
+ "c_timestamp":"2022-08-09T09:32:00",
+ "c_row":{
+ "C_MAP":{
+ "qMdUz":"ylcLM",
+ "bcwFI":"qgkJT",
+ "lrPiD":"JRdjf",
+ "zmRix":"uqOKy",
+ "NEHDJ":"tzJbU"
+ },
+ "C_ARRAY":[
+ 951883741,
+ 2012849301,
+ 1709478035,
+ 1095210330,
+ 94263648
+ ],
+ "C_STRING":"VAdKg",
+ "C_BOOLEAN":true,
+ "C_TINYINT":-121,
+ "C_SMALLINT":24543,
+ "C_INT":1853224936,
+ "C_BIGINT":6511613165105889280,
+ "C_FLOAT":248867480000000000000000000000000000000,
+
"C_DOUBLE":167553012802413800000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "C_BYTES":"UnNlRXo=",
+ "C_DATE":"2022-01-26",
+ "C_DECIMAL":50854841532374241314.109746688054104586,
+ "C_TIMESTAMP":"2022-02-18T22:33:00"
+ }
+ },
+ {
+ "c_map":{
+ "VLlqs":"OwUpp",
+ "MWXek":"KDEYD",
+ "RAZII":"zGJSJ",
+ "wjBNl":"IPTvu",
+ "YkGPS":"ORquf"
+ },
+ "c_array":[
+ 1530393427,
+ 2055877022,
+ 1389865473,
+ 926021483,
+ 402841214
+ ],
+ "c_string":"TNcNF",
+ "c_boolean":false,
+ "c_tinyint":-93,
+ "c_smallint":26429,
+ "c_int":1890712921,
+ "c_bigint":78884499049828080,
+ "c_float":78168420000000000000000000000000000000,
+
"c_double":78525745220115830000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "c_bytes":"cHhzZVA=",
+ "c_date":"2022-06-05",
+ "c_decimal":32486229951636021942.906126821535443395,
+ "c_timestamp":"2022-04-09T16:03:00",
+ "c_row":{
+ "C_MAP":{
+ "yIfRN":"gTBEL",
+ "oUnIJ":"GtmSz",
+ "IGuwP":"TyCOu",
+ "BwTUT":"HgnUn",
+ "MFrOg":"csTeq"
+ },
+ "C_ARRAY":[
+ 306983370,
+ 1604264996,
+ 2038631670,
+ 265692923,
+ 717846839
+ ],
+ "C_STRING":"wavDf",
+ "C_BOOLEAN":true,
+ "C_TINYINT":-48,
+ "C_SMALLINT":29740,
+ "C_INT":1691565731,
+ "C_BIGINT":6162480816264462336,
+ "C_FLOAT":332183420000000000000000000000000000000,
+
"C_DOUBLE":99936669025917730000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "C_BYTES":"RnVoR0Q=",
+ "C_DATE":"2022-04-09",
+ "C_DECIMAL":81349181592680914623.14214231545254843,
+ "C_TIMESTAMP":"2022-11-06T02:58:00"
+ }
+ },
+ {
+ "c_map":{
+ "OSHIu":"FlSum",
+ "MaSwp":"KYQkK",
+ "iXmjf":"zlkgq",
+ "jOBeN":"RDfwI",
+ "mNmag":"QyxeW"
+ },
+ "c_array":[
+ 1632475346,
+ 1988402914,
+ 1222138765,
+ 1952120146,
+ 1223582179
+ ],
+ "c_string":"fUmcz",
+ "c_boolean":false,
+ "c_tinyint":86,
+ "c_smallint":2122,
+ "c_int":798530029,
+ "c_bigint":4622710207120546816,
+ "c_float":274385260000000000000000000000000000000,
+
"c_double":3710018378162975000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "c_bytes":"WWlCdWk=",
+ "c_date":"2022-10-08",
+ "c_decimal":21195432655142738238.345609599825344131,
+ "c_timestamp":"2022-01-12T10:58:00",
+ "c_row":{
+ "C_MAP":{
+ "HdaHZ":"KMWIb",
+ "ETTGr":"zDkTq",
+ "kdTfa":"AyDqd",
+ "beLSj":"gCVdP",
+ "RDgtj":"YhJcx"
+ },
+ "C_ARRAY":[
+ 1665702810,
+ 2138839494,
+ 2129312562,
+ 1248002085,
+ 1536850903
+ ],
+ "C_STRING":"jJotn",
+ "C_BOOLEAN":false,
+ "C_TINYINT":90,
+ "C_SMALLINT":5092,
+ "C_INT":543799429,
+ "C_BIGINT":3526775209703891968,
+ "C_FLOAT":19285203000000000000000000000000000000,
+
"C_DOUBLE":119569847888769830000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "C_BYTES":"RVd4a1g=",
+ "C_DATE":"2022-09-19",
+ "C_DECIMAL":86909407361565847023.835229924753629936,
+ "C_TIMESTAMP":"2022-09-15T18:06:00"
+ }
+ },
+ {
+ "c_map":{
+ "aDAzK":"sMIOi",
+ "NSyDX":"TKSoT",
+ "JLxhC":"NpeWZ",
+ "LAjup":"KmHDA",
+ "HUIPE":"yAOKq"
+ },
+ "c_array":[
+ 1046349188,
+ 1243865078,
+ 849372657,
+ 522012053,
+ 644827083
+ ],
+ "c_string":"pwRSn",
+ "c_boolean":true,
+ "c_tinyint":55,
+ "c_smallint":14285,
+ "c_int":290002708,
+ "c_bigint":4717741595193431040,
+ "c_float":309654730000000000000000000000000000000,
+
"c_double":129844722952577660000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "c_bytes":"TE1oUWg=",
+ "c_date":"2022-05-05",
+ "c_decimal":75406296065465000885.249652183329686608,
+ "c_timestamp":"2022-07-05T14:40:00",
+ "c_row":{
+ "C_MAP":{
+ "WTqxL":"RuJsv",
+ "UXnhR":"HOjTp",
+ "EeFOQ":"PSpGy",
+ "YtxFI":"ACjTB",
+ "YAlWV":"NlOjQ"
+ },
+ "C_ARRAY":[
+ 1610325348,
+ 1432388472,
+ 557306114,
+ 590115029,
+ 1704913966
+ ],
+ "C_STRING":"Pnkxe",
+ "C_BOOLEAN":false,
+ "C_TINYINT":-15,
+ "C_SMALLINT":8909,
+ "C_INT":2084130154,
+ "C_BIGINT":3344333580258222592,
+ "C_FLOAT":333064730000000000000000000000000000000,
+
"C_DOUBLE":92331438173921840000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000,
+ "C_BYTES":"enpuUXk=",
+ "C_DATE":"2022-07-01",
+ "C_DECIMAL":87998983887293909887.925694693860636437,
+ "C_TIMESTAMP":"2022-02-12T07:45:00"
+ }
+ }
+ ],
+ "headers": {
+ "Content-Type": "application/json"
+ }
+ }
+ },
+ {
+ "httpRequest": {
+ "secure": true,
+ "method" : "GET",
+ "path": "/example/https"
+ },
+ "httpResponse": {
+ "body": [
+ {
+ "name": "1",
+ "age": 18
+ },
+ {
+ "name": "2",
+ "age": 19
+ }
+ ],
+ "headers": {
+ "Content-Type": "application/json"
+ }
+ }
+ },
+ {
+ "httpRequest": {
+ "method" : "GET",
+ "path": "/example/page",
+ "queryStringParameters": {
+ "pn": "1"
+ }
+ },
+ "httpResponse": {
+ "body": [
+ {
+ "name": "1",
+ "age": 18
+ },
+ {
+ "name": "2",
+ "age": 19
+ }
+ ],
+ "headers": {
+ "Content-Type": "application/json"
+ }
+ }
+ },
+ {
+ "httpRequest": {
+ "method" : "GET",
+ "path": "/example/page",
+ "queryStringParameters": {
+ "pn": "2"
+ }
+ },
+ "httpResponse": {
+ "body": [
+ {
+ "name": "1",
+ "age": 18
+ },
+ {
+ "name": "2",
+ "age": 19
+ }
+ ],
+ "headers": {
+ "Content-Type": "application/json"
+ }
+ }
+ }
+]
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
b/seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
index e5d8ca076..eb8614495 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml
@@ -33,6 +33,7 @@
<module>connector-amazondynamodb-e2e</module>
<module>connector-file-local-e2e</module>
<module>connector-cassandra-e2e</module>
+ <module>connector-http-e2e</module>
</modules>
<artifactId>seatunnel-connector-v2-e2e</artifactId>
