This is an automated email from the ASF dual-hosted git repository.
kirs 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 8056683f Remove connector listing (#1765)
8056683f is described below
commit 8056683f82e456f5ba6c42d3a3b184faabc5a73f
Author: Wenjun Ruan <[email protected]>
AuthorDate: Thu Apr 28 14:26:58 2022 +0800
Remove connector listing (#1765)
---
pom.xml | 2 +
seatunnel-connectors/plugin-mapping.properties | 1 +
seatunnel-connectors/pom.xml | 4 +-
.../seatunnel-connectors-flink-dist/pom.xml | 113 ++++++++++++
.../seatunnel-connectors-spark-dist/pom.xml | 190 +++++++++++++++++++++
.../seatunnel-connector-spark-clickhouse/pom.xml | 1 +
.../pom.xml | 1 +
.../seatunnel-connector-spark-email/pom.xml | 1 +
.../seatunnel-connector-spark-hbase/pom.xml | 1 +
.../seatunnel-connector-spark-http/pom.xml | 1 +
.../seatunnel-connector-spark-mongodb/pom.xml | 1 +
.../seatunnel-connector-spark-phoenix/pom.xml | 1 +
.../seatunnel-connector-spark-webhook/pom.xml | 1 +
seatunnel-dist/src/main/assembly/assembly-bin.xml | 24 +--
.../apache/seatunnel/e2e/flink/FlinkContainer.java | 2 +-
.../apache/seatunnel/e2e/spark/SparkContainer.java | 2 +-
.../src/test/resources/log4j.properties | 2 +-
.../seatunnel-flink-examples/pom.xml | 17 +-
.../seatunnel-flink-sql-examples/pom.xml | 7 +-
.../seatunnel-spark-examples/pom.xml | 19 ++-
20 files changed, 356 insertions(+), 35 deletions(-)
diff --git a/pom.xml b/pom.xml
index ba03cb21..141b5b29 100644
--- a/pom.xml
+++ b/pom.xml
@@ -169,6 +169,7 @@
<skipUT>false</skipUT>
<skipIT>true</skipIT>
<elasticsearch>7</elasticsearch>
+ <slf4j.version>1.7.25</slf4j.version>
</properties>
<dependencyManagement>
@@ -901,6 +902,7 @@
<excludedScopes>test,provided</excludedScopes>
</configuration>
</plugin>
+
</plugins>
</pluginManagement>
diff --git a/seatunnel-connectors/plugin-mapping.properties
b/seatunnel-connectors/plugin-mapping.properties
index c53625e6..58536d02 100644
--- a/seatunnel-connectors/plugin-mapping.properties
+++ b/seatunnel-connectors/plugin-mapping.properties
@@ -21,6 +21,7 @@
# Flink Source
flink.source.DruidSource = seatunnel-connector-flink-druid
flink.source.FakeSource = seatunnel-connector-flink-fake
+flink.source.FakeSourceStream = seatunnel-connector-flink-fake
flink.source.FileSource = seatunnel-connector-flink-file
flink.source.InfluxDbSource = seatunnel-connector-flink-influxdb
flink.source.JdbcSource = seatunnel-connector-flink-jdbc
diff --git a/seatunnel-connectors/pom.xml b/seatunnel-connectors/pom.xml
index 8e3ca7a5..69a02445 100644
--- a/seatunnel-connectors/pom.xml
+++ b/seatunnel-connectors/pom.xml
@@ -32,9 +32,9 @@
<modules>
<module>seatunnel-connectors-flink</module>
- <module>seatunnel-connectors-flink-list</module>
+ <module>seatunnel-connectors-flink-dist</module>
<module>seatunnel-connectors-spark</module>
- <module>seatunnel-connectors-spark-list</module>
+ <module>seatunnel-connectors-spark-dist</module>
</modules>
</project>
diff --git a/seatunnel-connectors/seatunnel-connectors-flink-dist/pom.xml
b/seatunnel-connectors/seatunnel-connectors-flink-dist/pom.xml
new file mode 100644
index 00000000..37808da3
--- /dev/null
+++ b/seatunnel-connectors/seatunnel-connectors-flink-dist/pom.xml
@@ -0,0 +1,113 @@
+<?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";>
+ <parent>
+ <artifactId>seatunnel-connectors</artifactId>
+ <groupId>org.apache.seatunnel</groupId>
+ <version>${revision}</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+
+ <artifactId>seatunnel-connectors-flink-dist</artifactId>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-kafka</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-console</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-jdbc</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-fake</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-socket</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-file</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-elasticsearch6</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-elasticsearch7</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-doris</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-clickhouse</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-dependency-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>copy-connector</id>
+ <phase>package</phase>
+ <goals>
+ <goal>copy-dependencies</goal>
+ </goals>
+ <configuration>
+ <type>jar</type>
+ <includeTypes>jar</includeTypes>
+
<outputDirectory>${project.build.directory}/lib</outputDirectory>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
\ No newline at end of file
diff --git a/seatunnel-connectors/seatunnel-connectors-spark-dist/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark-dist/pom.xml
new file mode 100644
index 00000000..715b7f2b
--- /dev/null
+++ b/seatunnel-connectors/seatunnel-connectors-spark-dist/pom.xml
@@ -0,0 +1,190 @@
+<?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";>
+ <parent>
+ <artifactId>seatunnel-connectors</artifactId>
+ <groupId>org.apache.seatunnel</groupId>
+ <version>${revision}</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+
+ <artifactId>seatunnel-connectors-spark-dist</artifactId>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-kafka</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-fake</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-file</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-socket</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-jdbc</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-elasticsearch</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-hive</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-phoenix</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-redis</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-mongodb</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-kudu</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-email</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-console</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-clickhouse</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-hbase</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-hudi</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-doris</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-tidb</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-neo4j</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-iceberg</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-feishu</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-http</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-webhook</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-dependency-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>copy-connector</id>
+ <phase>package</phase>
+ <goals>
+ <goal>copy-dependencies</goal>
+ </goals>
+ <configuration>
+ <type>jar</type>
+ <includeTypes>jar</includeTypes>
+
<outputDirectory>${project.build.directory}/lib</outputDirectory>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
\ No newline at end of file
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
index f590d5e6..d255ab9e 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
@@ -33,6 +33,7 @@
<dependency>
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
+ <scope>provided</scope>
<version>${project.version}</version>
</dependency>
<dependency>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
index 5987a6a1..792a3e8e 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
@@ -34,6 +34,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
index d0bad434..650b8c60 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
@@ -34,6 +34,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
<groupId>com.norbitltd</groupId>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
index 22c17384..8fe340c4 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
@@ -34,6 +34,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/pom.xml
index df3ef7b6..758a7fca 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-http/pom.xml
@@ -34,6 +34,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
index 2cf33c30..75430b85 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
@@ -30,6 +30,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
index c02eff97..1d54e180 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
@@ -34,6 +34,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/pom.xml
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/pom.xml
index 72fb986d..0a7a9246 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/pom.xml
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook/pom.xml
@@ -34,6 +34,7 @@
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-api-spark</artifactId>
<version>${project.version}</version>
+ <scope>provided</scope>
</dependency>
<dependency>
diff --git a/seatunnel-dist/src/main/assembly/assembly-bin.xml
b/seatunnel-dist/src/main/assembly/assembly-bin.xml
index f97a4c16..aaa25e23 100644
--- a/seatunnel-dist/src/main/assembly/assembly-bin.xml
+++ b/seatunnel-dist/src/main/assembly/assembly-bin.xml
@@ -89,7 +89,7 @@
<outputDirectory>/lib</outputDirectory>
</fileSet>
<fileSet>
-
<directory>../seatunnel-connectors/seatunnel-connectors-flink-list/seatunnel-connectors-flink-list-current/target/lib</directory>
+
<directory>../seatunnel-connectors/seatunnel-connectors-flink-dist/target/lib</directory>
<includes>
<include>seatunnel-connector-flink*.jar</include>
</includes>
@@ -99,7 +99,7 @@
<outputDirectory>/connectors/flink</outputDirectory>
</fileSet>
<fileSet>
-
<directory>../seatunnel-connectors/seatunnel-connectors-spark-list/seatunnel-connectors-spark-list-current/target/lib</directory>
+
<directory>../seatunnel-connectors/seatunnel-connectors-spark-dist/target/lib</directory>
<includes>
<include>seatunnel-connector-spark*.jar</include>
</includes>
@@ -108,26 +108,6 @@
</excludes>
<outputDirectory>/connectors/spark</outputDirectory>
</fileSet>
- <fileSet>
-
<directory>../seatunnel-connectors/seatunnel-connectors-flink-list/seatunnel-connectors-flink-list-previous/target/lib</directory>
- <includes>
- <include>seatunnel-connector-flink*.jar</include>
- </includes>
- <excludes>
- <exclude>%regex[.*((javadoc)|(sources))\.jar]</exclude>
- </excludes>
- <outputDirectory>/opt/flink</outputDirectory>
- </fileSet>
- <fileSet>
-
<directory>../seatunnel-connectors/seatunnel-connectors-spark-list/seatunnel-connectors-spark-list-previous/target/lib</directory>
- <includes>
- <include>seatunnel-connector-spark*.jar</include>
- </includes>
- <excludes>
- <exclude>%regex[.*((javadoc)|(sources))\.jar]</exclude>
- </excludes>
- <outputDirectory>/opt/spark</outputDirectory>
- </fileSet>
<fileSet>
<directory>../seatunnel-connectors</directory>
<includes>
diff --git
a/seatunnel-e2e/seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
b/seatunnel-e2e/seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
index 43462b60..52019de6 100644
---
a/seatunnel-e2e/seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
+++
b/seatunnel-e2e/seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
@@ -136,7 +136,7 @@ public abstract class FlinkContainer {
// copy connectors jar
File jars = new File(PROJECT_ROOT_PATH +
-
"/seatunnel-connectors/seatunnel-connectors-flink-list/seatunnel-connectors-flink-list-current/target/lib");
+
"/seatunnel-connectors/seatunnel-connectors-flink-dist/target/lib");
Arrays.stream(Objects.requireNonNull(jars.listFiles(f ->
f.getName().startsWith("seatunnel-connector-flink"))))
.forEach(jar ->
jobManager.copyFileToContainer(
diff --git
a/seatunnel-e2e/seatunnel-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java
b/seatunnel-e2e/seatunnel-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java
index c3219715..dcd20b3b 100644
---
a/seatunnel-e2e/seatunnel-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java
+++
b/seatunnel-e2e/seatunnel-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/SparkContainer.java
@@ -156,7 +156,7 @@ public abstract class SparkContainer {
private List<File> getConnectorJarFiles() {
File jars = new File(PROJECT_ROOT_PATH +
-
"/seatunnel-connectors/seatunnel-connectors-spark-list/seatunnel-connectors-spark-list-current/target/lib");
+
"/seatunnel-connectors/seatunnel-connectors-spark-dist/target/lib");
return Arrays.stream(
Objects.requireNonNull(
jars.listFiles(
diff --git
a/seatunnel-e2e/seatunnel-spark-e2e/src/test/resources/log4j.properties
b/seatunnel-e2e/seatunnel-spark-e2e/src/test/resources/log4j.properties
index 900b94e2..89547981 100644
--- a/seatunnel-e2e/seatunnel-spark-e2e/src/test/resources/log4j.properties
+++ b/seatunnel-e2e/seatunnel-spark-e2e/src/test/resources/log4j.properties
@@ -15,7 +15,7 @@
# limitations under the License.
#
# Set everything to be logged to the console
-log4j.rootCategory=info, console
+log4j.rootCategory=ERROR, console
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.target=System.err
log4j.appender.console.layout=org.apache.log4j.PatternLayout
diff --git a/seatunnel-examples/seatunnel-flink-examples/pom.xml
b/seatunnel-examples/seatunnel-flink-examples/pom.xml
index 7479221c..79fbe8f1 100644
--- a/seatunnel-examples/seatunnel-flink-examples/pom.xml
+++ b/seatunnel-examples/seatunnel-flink-examples/pom.xml
@@ -30,7 +30,6 @@
<artifactId>seatunnel-flink-examples</artifactId>
<properties>
<flink.scope>compile</flink.scope>
- <connector.scope>compile</connector.scope>
</properties>
<dependencies>
@@ -46,12 +45,18 @@
<version>${project.version}</version>
</dependency>
+ <!-- seatunnel-connector -->
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors-flink-list-current</artifactId>
+ <artifactId>seatunnel-connector-flink-fake</artifactId>
<version>${project.version}</version>
- <scope>${connector.scope}</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-flink-console</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <!-- seatunnel connectors -->
<!--flink-->
<dependency>
@@ -84,6 +89,12 @@
<version>${flink.version}</version>
<scope>${flink.scope}</scope>
</dependency>
+
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>${slf4j.version}</version>
+ </dependency>
</dependencies>
</project>
\ No newline at end of file
diff --git a/seatunnel-examples/seatunnel-flink-sql-examples/pom.xml
b/seatunnel-examples/seatunnel-flink-sql-examples/pom.xml
index 5151e77a..63a714fd 100644
--- a/seatunnel-examples/seatunnel-flink-sql-examples/pom.xml
+++ b/seatunnel-examples/seatunnel-flink-sql-examples/pom.xml
@@ -90,6 +90,11 @@
<version>${flink.version}</version>
<scope>${flink.scope}</scope>
</dependency>
-
+
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>${slf4j.version}</version>
+ </dependency>
</dependencies>
</project>
diff --git a/seatunnel-examples/seatunnel-spark-examples/pom.xml
b/seatunnel-examples/seatunnel-spark-examples/pom.xml
index 139ccfd3..6b9d2c79 100644
--- a/seatunnel-examples/seatunnel-spark-examples/pom.xml
+++ b/seatunnel-examples/seatunnel-spark-examples/pom.xml
@@ -30,21 +30,26 @@
<artifactId>seatunnel-spark-examples</artifactId>
<properties>
<spark.scope>compile</spark.scope>
- <connector.scope>compile</connector.scope>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-core-spark</artifactId>
- <version>${project.parent.version}</version>
+ <version>${project.version}</version>
</dependency>
+ <!-- seatunnel connectors -->
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connector-spark-fake</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors-spark-list-current</artifactId>
+ <artifactId>seatunnel-connector-spark-console</artifactId>
<version>${project.version}</version>
- <scope>${connector.scope}</scope>
</dependency>
+ <!-- seatunnel connectors -->
<!--spark-->
<dependency>
@@ -79,5 +84,11 @@
<artifactId>lz4</artifactId>
<version>1.3.0</version>
</dependency>
+
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>${slf4j.version}</version>
+ </dependency>
</dependencies>
</project>
\ No newline at end of file
