This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from cbf82f755 [DEV][Api] Replace SeaTunnelContext with JobContext and
remove singleton pattern (#2706)
add 547a6be2d [Starter] [Core] Modify connector v2 starter (#2726)
No new revisions were added by this update.
Summary of changes:
pom.xml | 8 ++
seatunnel-apis/seatunnel-api-base/pom.xml | 5 --
seatunnel-core/seatunnel-core-starter/pom.xml | 10 +--
.../starter/config/AbstractExecutionContext.java | 92 ----------------------
.../core/starter/config/EnvironmentFactory.java | 26 ++----
.../core/starter/config/ExecutionFactory.java | 84 --------------------
seatunnel-core/seatunnel-flink-starter/pom.xml | 6 --
...or.sh => start-seatunnel-flink-connector-v2.sh} | 0
.../seatunnel/core/starter/flink/FlinkStarter.java | 4 +-
.../core/starter/flink/SeatunnelFlink.java | 4 +-
...nkJobType.java => FlinkEnvironmentFactory.java} | 19 ++---
.../core/starter/flink/config/StarterConstant.java | 7 +-
.../starter/flink/execution/FlinkExecution.java | 15 ++--
seatunnel-core/seatunnel-spark-starter/pom.xml | 6 --
...or.sh => start-seatunnel-spark-connector-v2.sh} | 2 +-
.../core/starter/spark/SeatunnelSpark.java | 3 +-
.../seatunnel/core/starter/spark/SparkStarter.java | 3 +-
.../spark/config/SparkApiConfigChecker.java | 1 +
.../starter/spark/config/SparkEnvironment.java | 66 ----------------
...igChecker.java => SparkEnvironmentFactory.java} | 14 ++--
.../core/starter/spark/config/StarterConstant.java | 7 +-
.../starter/spark/execution/SparkExecution.java | 8 +-
seatunnel-dist/release-docs/LICENSE | 5 --
.../apache/seatunnel/e2e/flink/FlinkContainer.java | 2 +-
.../apache/seatunnel/e2e/spark/SparkContainer.java | 2 +-
tools/dependencies/known-dependencies.txt | 7 +-
26 files changed, 67 insertions(+), 339 deletions(-)
delete mode 100644
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/AbstractExecutionContext.java
delete mode 100644
seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/config/ExecutionFactory.java
rename
seatunnel-core/seatunnel-flink-starter/src/main/bin/{start-seatunnel-flink-new-connector.sh
=> start-seatunnel-flink-connector-v2.sh} (100%)
rename
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/{FlinkJobType.java
=> FlinkEnvironmentFactory.java} (66%)
copy
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitEnumeratorState.java
=>
seatunnel-core/seatunnel-flink-starter/src/main/java/org/apache/seatunnel/core/starter/flink/config/StarterConstant.java
(82%)
rename
seatunnel-core/seatunnel-spark-starter/src/main/bin/{start-seatunnel-spark-new-connector.sh
=> start-seatunnel-spark-connector-v2.sh} (95%)
delete mode 100644
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/config/SparkEnvironment.java
copy
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/config/{SparkApiConfigChecker.java
=> SparkEnvironmentFactory.java} (69%)
copy
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitEnumeratorState.java
=>
seatunnel-core/seatunnel-spark-starter/src/main/java/org/apache/seatunnel/core/starter/spark/config/StarterConstant.java
(82%)
