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/seatunnel.git
from 71854ba32d [Build] Update snapshot version to 2.3.5 (#6377)
add 9c3c2f183d [Improve][Zeta] Add classloader cache mode to fix metaspace
leak (#6355)
No new revisions were added by this update.
Summary of changes:
docs/en/seatunnel-engine/deployment.md | 14 ++
.../source/enumerator/AbstractSplitEnumerator.java | 3 -
.../iceberg/source/reader/IcebergSourceReader.java | 3 -
.../influxdb/sink/InfluxDBSinkWriter.java | 3 -
.../source/InfluxDBSourceSplitEnumerator.java | 6 +-
.../influxdb/source/InfluxdbSourceReader.java | 3 -
.../container/seatunnel/SeaTunnelContainer.java | 6 +-
.../seatunnel/e2e/common/util/ContainerUtil.java | 2 +-
.../e2e/sink/inmemory/InMemorySinkWriter.java | 23 +++
.../engine/e2e/ClusterSeaTunnelContainer.java | 2 -
.../classloader/ClassLoaderDisableCacheModeIT.java | 13 +-
.../classloader/ClassLoaderEnableCacheModeIT.java | 13 +-
.../engine/e2e/classloader/ClassLoaderITBase.java | 151 ++++++++++++++++++++
.../resources/classloader/fake_to_inmemory.conf | 4 +-
.../classloader}/plugin-mapping.properties | 3 +-
.../seatunnel_cache_mode.yaml} | 1 +
.../seatunnel_disable_cache_mode.yaml} | 1 +
.../engine/common/config/EngineConfig.java | 3 +
.../config/YamlSeaTunnelDomConfigProcessor.java | 2 +
.../common/config/server/ServerConfigOptions.java | 7 +
.../loader/SeaTunnelChildFirstClassLoader.java | 8 +-
.../seatunnel/engine/server/SeaTunnelServer.java | 17 ++-
.../engine/server/TaskExecutionService.java | 50 ++++---
.../engine/server/dag/physical/PhysicalVertex.java | 1 +
.../engine/server/execution/TaskGroupContext.java | 4 +
.../seatunnel/engine/server/master/JobMaster.java | 13 +-
.../server/rest/RestHttpGetCommandProcessor.java | 15 +-
.../service/classloader/ClassLoaderService.java | 38 +++--
.../classloader/DefaultClassLoaderService.java | 155 +++++++++++++++++++++
.../server/task/TaskGroupImmutableInformation.java | 3 +
.../AbstractClassLoaderServiceTest.java | 113 +++++++++++++++
.../ClassLoaderServiceCacheModeTest.java | 72 ++++++++++
.../classloader/ClassLoaderServiceTest.java | 72 ++++++++++
33 files changed, 733 insertions(+), 91 deletions(-)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/group/queue/disruptor/RecordEventFactory.java
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/classloader/ClassLoaderDisableCacheModeIT.java
(74%)
copy
seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceSplit.java
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/classloader/ClassLoaderEnableCacheModeIT.java
(75%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/classloader/ClassLoaderITBase.java
copy
seatunnel-core/seatunnel-starter/src/test/resources/config/fake_to_inmemory_multi_table.conf
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/classloader/fake_to_inmemory.conf
(96%)
copy
seatunnel-e2e/seatunnel-engine-e2e/{seatunnel-engine-k8s-e2e/src/test/resources/custom_config
=>
connector-seatunnel-e2e-base/src/test/resources/classloader}/plugin-mapping.properties
(96%)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{seatunnel.yaml
=> classloader/seatunnel_cache_mode.yaml} (97%)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{seatunnel.yaml
=> classloader/seatunnel_disable_cache_mode.yaml} (97%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/ConfigShade.java
=>
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/classloader/ClassLoaderService.java
(53%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/classloader/DefaultClassLoaderService.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/service/classloader/AbstractClassLoaderServiceTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/service/classloader/ClassLoaderServiceCacheModeTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/service/classloader/ClassLoaderServiceTest.java
