This is an automated email from the ASF dual-hosted git repository.
zhangshenghang pushed a change to branch fix-socket-source-reader-lifecycle
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from e04a7c2266 Merge remote-tracking branch 'upstream/dev' into
fix-socket-source-reader-lifecycle
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 e78073ce66 Merge remote-tracking branch 'upstream/dev' into
fix-socket-source-reader-lifecycle
No new revisions were added by this update.
Summary of changes:
README.md | 3 +-
docs/en/engines/zeta/telemetry.md | 9 +
.../locally/quick-start-seatunnel-engine.md | 3 +-
.../getting-started/locally/run-your-first-job.md | 99 +++++++
.../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/introduction/about.md | 26 +-
docs/sidebars.js | 29 ++
docs/zh/engines/zeta/telemetry.md | 9 +
.../locally/quick-start-seatunnel-engine.md | 3 +-
.../getting-started/locally/run-your-first-job.md | 99 +++++++
.../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/introduction/about.md | 26 +-
.../seatunnel/api/table/factory/FactoryUtil.java | 8 +-
.../api/table/catalog/CatalogTableUtilTest.java | 66 +++++
.../jdbc/catalog/duckdb/DuckDBCatalogFactory.java | 12 +-
.../lance/catalog/LanceCatalogFactory.java | 2 +-
.../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 +-
57 files changed, 4295 insertions(+), 544 deletions(-)
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/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
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
