This is an automated email from the ASF dual-hosted git repository.
zhangshenghang pushed a change to branch fix-jdbc-catalog-close-leak
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 7ebdd4e7c6 Merge remote-tracking branch 'upstream/dev' into
fix-jdbc-catalog-close-leak
add b7d3f1515f [Improve][Zeta] Add ReportMetricsOperation observability
exports (#11104)
add df28704d92 [Docs] Update CNCF landscape license link (#11149)
add b5fd7601bd [Docs] Add first-job entry and getting started recipes
(#11058)
add d774e8ee8c [Feature][Zeta] Decouple Hazelcast IMap via StateStore
Abstraction (#10812)
add 0e2f4ef8d5 [Fix][API] Add missing OptionRule validation for
CatalogFactory creation path (#11127)
add e83aeb41af [Test][E2E] Stabilize schema evolution add-column
assertions (#11154)
add 00c7871c1c [Docs] Fix Chinese engine architecture page rendering
(#11164)
add 152c410882 [Fix][seatunnel-translation-base] Remove connector-specific
test dependencies from translation base (#11075)
add 60e026bd0a [Docs] Improve new user onboarding flow (#11152)
add 8e706fc9a0 Merge remote-tracking branch 'upstream/dev' into
fix-jdbc-catalog-close-leak
No new revisions were added by this update.
Summary of changes:
README.md | 3 +-
docs/en/connectors/formats/overview.md | 19 ++
docs/en/connectors/overview.md | 39 +++
docs/en/connectors/sink-overview.md | 21 ++
docs/en/connectors/source-overview.md | 21 ++
docs/en/engines/zeta/telemetry.md | 9 +
docs/en/getting-started/job-configuration-guide.md | 1 +
docs/en/getting-started/locally/deployment.md | 7 +
docs/en/getting-started/locally/overview.md | 29 ++
.../locally/quick-start-seatunnel-engine.md | 3 +-
.../getting-started/locally/run-your-first-job.md | 99 ++++++
docs/en/getting-started/overview.md | 3 +
.../getting-started/recipes/file-to-starrocks.md | 145 +++++++++
docs/en/getting-started/recipes/http-to-jdbc.md | 126 ++++++++
docs/en/getting-started/recipes/jdbc-to-s3.md | 137 ++++++++
.../en/getting-started/recipes/kafka-to-iceberg.md | 138 +++++++++
docs/en/getting-started/recipes/multi-table-cdc.md | 204 ++++++++++++
.../getting-started/recipes/mysql-cdc-to-doris.md | 177 +++++++++++
docs/en/getting-started/recipes/overview.md | 25 ++
docs/en/introduction/about.md | 125 ++++----
docs/en/introduction/concepts/config.md | 68 ++--
docs/en/introduction/how-it-works.md | 34 ++
docs/en/transforms/overview.md | 23 ++
docs/sidebars.js | 221 +++++++------
docs/zh/architecture/engine/engine-architecture.md | 1 -
docs/zh/connectors/connector-faq.md | 65 ----
.../zh/connectors/connector-isolated-dependency.md | 25 +-
docs/zh/connectors/formats/overview.md | 19 ++
docs/zh/connectors/overview.md | 39 +++
docs/zh/connectors/sink-overview.md | 21 ++
docs/zh/connectors/source-overview.md | 21 ++
docs/zh/engines/zeta/telemetry.md | 9 +
docs/zh/getting-started/job-configuration-guide.md | 5 +-
docs/zh/getting-started/locally/deployment.md | 7 +
docs/zh/getting-started/locally/overview.md | 29 ++
.../locally/quick-start-seatunnel-engine.md | 3 +-
.../getting-started/locally/run-your-first-job.md | 99 ++++++
docs/zh/getting-started/overview.md | 23 +-
.../getting-started/recipes/file-to-starrocks.md | 145 +++++++++
docs/zh/getting-started/recipes/http-to-jdbc.md | 126 ++++++++
docs/zh/getting-started/recipes/jdbc-to-s3.md | 137 ++++++++
.../zh/getting-started/recipes/kafka-to-iceberg.md | 138 +++++++++
docs/zh/getting-started/recipes/multi-table-cdc.md | 204 ++++++++++++
.../getting-started/recipes/mysql-cdc-to-doris.md | 177 +++++++++++
docs/zh/getting-started/recipes/overview.md | 25 ++
docs/zh/introduction/about.md | 131 ++++----
docs/zh/introduction/concepts/config.md | 64 ++--
docs/zh/introduction/how-it-works.md | 52 +++-
docs/zh/transforms/overview.md | 23 ++
.../seatunnel/api/table/factory/FactoryUtil.java | 8 +-
.../api/table/catalog/CatalogTableUtilTest.java | 66 ++++
.../jdbc/catalog/duckdb/DuckDBCatalogFactory.java | 12 +-
.../lance/catalog/LanceCatalogFactory.java | 2 +-
.../jdbc/AbstractSchemaChangeBaseIT.java | 78 ++---
.../src/test/resources/ddl/add_columns.sql | 7 +-
.../apache/seatunnel/engine/common/Constant.java | 4 -
.../engine/server/CoordinatorService.java | 169 +---------
.../seatunnel/engine/server/SeaTunnelServer.java | 98 ++----
.../engine/server/TaskExecutionService.java | 81 ++++-
.../monitor/CheckpointMonitorService.java | 213 +------------
.../server/common/SeaTunnelEngineContext.java | 69 +++++
.../statestore/AuthoritativeStateStores.java | 33 +-
.../common/statestore/AuxiliaryStateStores.java | 54 ++++
.../DefaultAuthoritativeStateStores.java | 6 +-
.../statestore/DefaultAuxiliaryStateStores.java | 66 ++++
.../common/statestore/EngineStateStoreNames.java | 20 +-
.../common/statestore/EngineStateStores.java | 75 +++++
.../common/statestore/IterableStateStore.java | 57 ++++
.../server/common/statestore/StateStore.java | 100 ++++++
.../checkpoint/CheckpointOverviewStateStore.java | 67 ++++
.../HazelcastCheckpointOverviewStateStore.java | 282 +++++++++++++++++
.../hazelcast/HazelcastEngineStateStores.java | 100 ++++++
.../metrics/MetricsSnapshotStateStore.java | 113 +++++++
.../HazelcastMetricsSnapshotStateStore.java | 322 +++++++++++++++++++
.../server/execution/TaskExecutionContext.java | 29 +-
.../metrics/ExportsInstanceInitializer.java | 3 +
...unter.java => ReportMetricsOperationStats.java} | 24 +-
.../exports/EngineStateStoreMetricExports.java | 5 +-
.../exports/ReportMetricsOperationExports.java | 90 ++++++
.../CoordinatorServicePipelineCleanupTest.java | 12 +-
.../engine/server/CoordinatorServiceTest.java | 45 ++-
.../HazelcastCheckpointOverviewStateStoreTest.java | 133 ++++++++
.../HazelcastMetricsSnapshotStateStoreTest.java | 203 ++++++++++++
.../TelemetryCollectorCoordinatorGuardTest.java | 110 +++++++
.../EngineStateStoreLogicalMetricExportsTest.java | 3 +-
.../exports/EngineStateStoreMetricExportsTest.java | 5 +-
.../seatunnel-translation-base/pom.xml | 13 -
.../translation/source/ParallelSourceTest.java | 343 +++++++++++++--------
88 files changed, 5258 insertions(+), 1127 deletions(-)
create mode 100644 docs/en/connectors/formats/overview.md
create mode 100644 docs/en/connectors/overview.md
create mode 100644 docs/en/connectors/sink-overview.md
create mode 100644 docs/en/connectors/source-overview.md
create mode 100644 docs/en/getting-started/locally/overview.md
create mode 100644 docs/en/getting-started/locally/run-your-first-job.md
create mode 100644 docs/en/getting-started/recipes/file-to-starrocks.md
create mode 100644 docs/en/getting-started/recipes/http-to-jdbc.md
create mode 100644 docs/en/getting-started/recipes/jdbc-to-s3.md
create mode 100644 docs/en/getting-started/recipes/kafka-to-iceberg.md
create mode 100644 docs/en/getting-started/recipes/multi-table-cdc.md
create mode 100644 docs/en/getting-started/recipes/mysql-cdc-to-doris.md
create mode 100644 docs/en/getting-started/recipes/overview.md
create mode 100644 docs/en/transforms/overview.md
delete mode 100644 docs/zh/connectors/connector-faq.md
create mode 100644 docs/zh/connectors/formats/overview.md
create mode 100644 docs/zh/connectors/overview.md
create mode 100644 docs/zh/connectors/sink-overview.md
create mode 100644 docs/zh/connectors/source-overview.md
create mode 100644 docs/zh/getting-started/locally/overview.md
create mode 100644 docs/zh/getting-started/locally/run-your-first-job.md
create mode 100644 docs/zh/getting-started/recipes/file-to-starrocks.md
create mode 100644 docs/zh/getting-started/recipes/http-to-jdbc.md
create mode 100644 docs/zh/getting-started/recipes/jdbc-to-s3.md
create mode 100644 docs/zh/getting-started/recipes/kafka-to-iceberg.md
create mode 100644 docs/zh/getting-started/recipes/multi-table-cdc.md
create mode 100644 docs/zh/getting-started/recipes/mysql-cdc-to-doris.md
create mode 100644 docs/zh/getting-started/recipes/overview.md
create mode 100644 docs/zh/transforms/overview.md
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/SeaTunnelEngineContext.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/Collector.java =>
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/AuthoritativeStateStores.java
(55%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/AuxiliaryStateStores.java
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportMultiTableSink.java
=>
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/DefaultAuthoritativeStateStores.java
(78%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/DefaultAuxiliaryStateStores.java
copy
seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/serialize/source/EasysearchRecord.java
=>
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/EngineStateStoreNames.java
(67%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/EngineStateStores.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/IterableStateStore.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/StateStore.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/checkpoint/CheckpointOverviewStateStore.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/checkpoint/hazelcast/HazelcastCheckpointOverviewStateStore.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/hazelcast/HazelcastEngineStateStores.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/metrics/MetricsSnapshotStateStore.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/common/statestore/metrics/hazelcast/HazelcastMetricsSnapshotStateStore.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/telemetry/metrics/entity/{JobCounter.java
=> ReportMetricsOperationStats.java} (56%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/telemetry/metrics/exports/ReportMetricsOperationExports.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/common/statestore/checkpoint/hazelcast/HazelcastCheckpointOverviewStateStoreTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/common/statestore/metrics/hazelcast/HazelcastMetricsSnapshotStateStoreTest.java
