This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a change to branch
davidzollo_republish_11780_resolver_restore_fix
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from f2ef35145d [Test][Zeta] Declare checked lifecycle validation failure
add 619cdabf2b [Test][E2E] Give HANA and OceanBase e2e containers
realistic startup readiness (#12128)
add 7604a83ec8 [Feature][Zeta] Support environment-variable object storage
credential (#12885)
add 0cf767d0c8 [Fix][Connector-V2] Remove incorrect HTTP entity content
encoding (#11281)
add 9aeb282b2d [Docs] Fix option and config inaccuracies across transform,
Zeta engine and connector docs (#12423)
add c6a240c466 [Docs] Fix connector doc inaccuracies verified against
source code (#12615)
add 016f2c153f [Docs] Fix getting-started and engine docs verified against
source code (#12693)
add 570eb97611 [Fix][Zeta] Keep IMap entry expiration times across
restarts in the file map store (#12973)
add 5666e8d594 [Improve][Connector-V2][Doris] Warn when TIMESTAMP_TZ
columns use the JVM default zone (#12945)
add 50256f12c3 [Fix][Zeta] Preserve cancellation after worker failure
(#12377)
add eceeb0abad [Fix][Connector-V2][Jdbc] Write the net effect of each key
when reducing the sink batch (#12808)
add 4f5e329374 [Fix][Zeta] Exec the JVM in seatunnel-cluster.sh so SIGTERM
reaches it (#12710)
add de9b58a6d1 [Chore][Zeta] Refresh schema restore against current dev
No new revisions were added by this update.
Summary of changes:
.../templates/deployment-seatunnel-master.yaml | 5 +-
.../templates/deployment-seatunnel-worker.yaml | 5 +-
deploy/kubernetes/seatunnel/values.yaml | 6 +
docs/en/connectors/sink/AmazonDynamoDB.md | 2 +-
docs/en/connectors/sink/Doris.md | 2 +-
docs/en/connectors/sink/FtpFile.md | 22 +-
docs/en/connectors/source/FtpFile.md | 31 +--
docs/en/connectors/source/Hive.md | 14 +-
docs/en/engines/zeta/checkpoint-storage.md | 63 ++++++
docs/en/engines/zeta/hybrid-cluster-deployment.md | 21 +-
.../engines/zeta/separated-cluster-deployment.md | 21 +-
docs/en/engines/zeta/stain-trace.md | 4 +-
docs/en/engines/zeta/state-storage-and-recovery.md | 5 +-
docs/en/engines/zeta/telemetry.md | 13 +-
docs/en/engines/zeta/tuning-guide.md | 2 +
docs/en/getting-started/docker/docker.md | 43 ++--
.../en/getting-started/kubernetes/configuration.md | 66 +++++-
.../kubernetes/hybrid-cluster-mode.md | 20 +-
docs/en/getting-started/kubernetes/operations.md | 3 +-
.../kubernetes/separated-cluster-mode.md | 22 +-
docs/en/getting-started/locally/deployment.md | 10 +-
.../getting-started/locally/quick-start-flink.md | 7 +
.../getting-started/locally/run-your-first-job.md | 2 +-
.../getting-started/recipes/file-to-starrocks.md | 4 +-
docs/en/getting-started/recipes/http-to-jdbc.md | 4 +-
docs/en/getting-started/recipes/jdbc-to-jdbc.md | 4 +-
docs/en/getting-started/recipes/jdbc-to-s3.md | 6 +-
.../en/getting-started/recipes/kafka-to-iceberg.md | 2 +-
docs/en/getting-started/recipes/multi-table-cdc.md | 4 +-
.../getting-started/recipes/mysql-cdc-to-doris.md | 4 +-
.../submit-job-to-remote-zeta-cluster.md | 141 +++++++-----
docs/en/introduction/concepts/config.md | 2 +-
.../concepts/gravitino-type-mapping.md | 2 -
.../configuration/config-encryption-decryption.md | 2 +-
docs/en/transforms/dynamic-compile.md | 8 +-
docs/en/transforms/embedding.md | 4 +-
docs/en/transforms/filter-rowkind.md | 2 +-
docs/en/transforms/llm.md | 31 +--
docs/en/transforms/rowkind-extractor.md | 6 +-
docs/en/transforms/sql-udf.md | 2 +-
docs/zh/connectors/sink/AmazonDynamoDB.md | 2 +-
docs/zh/connectors/sink/Doris.md | 178 ++++++++++++++-
docs/zh/connectors/sink/FtpFile.md | 22 +-
docs/zh/connectors/source/FtpFile.md | 31 +--
docs/zh/connectors/source/Hive.md | 14 +-
docs/zh/engines/zeta/checkpoint-storage.md | 57 +++++
docs/zh/engines/zeta/hybrid-cluster-deployment.md | 16 +-
docs/zh/engines/zeta/rest-api-v2.md | 7 +
.../engines/zeta/separated-cluster-deployment.md | 16 +-
docs/zh/engines/zeta/stain-trace.md | 4 +-
docs/zh/engines/zeta/state-storage-and-recovery.md | 5 +-
docs/zh/engines/zeta/telemetry.md | 11 +
docs/zh/engines/zeta/tuning-guide.md | 2 +
docs/zh/getting-started/docker/docker.md | 45 ++--
.../zh/getting-started/kubernetes/configuration.md | 66 +++++-
.../kubernetes/hybrid-cluster-mode.md | 20 +-
docs/zh/getting-started/kubernetes/operations.md | 3 +-
.../kubernetes/separated-cluster-mode.md | 22 +-
docs/zh/getting-started/locally/deployment.md | 15 +-
.../getting-started/locally/quick-start-flink.md | 7 +
.../locally/quick-start-seatunnel-engine.md | 15 +-
.../getting-started/locally/run-your-first-job.md | 2 +-
.../getting-started/recipes/file-to-starrocks.md | 4 +-
docs/zh/getting-started/recipes/http-to-jdbc.md | 4 +-
docs/zh/getting-started/recipes/jdbc-to-jdbc.md | 4 +-
docs/zh/getting-started/recipes/jdbc-to-s3.md | 6 +-
.../zh/getting-started/recipes/kafka-to-iceberg.md | 2 +-
docs/zh/getting-started/recipes/multi-table-cdc.md | 4 +-
.../getting-started/recipes/mysql-cdc-to-doris.md | 4 +-
.../submit-job-to-remote-zeta-cluster.md | 136 +++++++-----
docs/zh/introduction/concepts/config.md | 2 +-
.../introduction/concepts/connector-v2-features.md | 4 +-
.../concepts/gravitino-type-mapping.md | 2 -
.../configuration/config-encryption-decryption.md | 7 +-
docs/zh/introduction/configuration/sql-config.md | 2 +-
docs/zh/transforms/dynamic-compile.md | 8 +-
docs/zh/transforms/embedding.md | 2 +
docs/zh/transforms/filter-rowkind.md | 2 +-
docs/zh/transforms/llm.md | 7 +-
docs/zh/transforms/replace.md | 2 +-
docs/zh/transforms/rowkind-extractor.md | 6 +-
docs/zh/transforms/sql-udf.md | 5 +-
.../doris/sink/writer/DorisSinkWriter.java | 81 +++++++
.../doris/sink/writer/DorisSinkWriterTest.java | 239 ++++++++++++++++++++-
.../http/client/HttpClientProviderTest.java | 20 ++
.../BufferReducedBatchStatementExecutor.java | 24 ++-
.../BufferReducedBatchStatementExecutorTest.java | 40 ++++
.../src/main/bin/seatunnel-cluster.sh | 3 +-
.../seatunnel/SeaTunnelClusterScriptTest.java | 19 ++
.../seatunnel/e2e/connector/doris/DorisIT.java | 89 ++++++++
... fake_timestamp_tz_to_doris_zone_explicit.conf} | 41 ++--
... => fake_timestamp_tz_to_doris_zone_unset.conf} | 40 ++--
.../common/junit/ContainerTestingExtension.java | 17 ++
.../junit/ContainerTestingExtensionTest.java | 100 +++++++++
.../engine/e2e/ClusterFaultToleranceIT.java | 106 +++++++++
.../engine/server/dag/physical/PhysicalPlan.java | 7 +
.../engine/server/dag/physical/SubPlan.java | 102 +++++++--
.../engine/server/persistence/FileMapStore.java | 52 ++++-
.../server/persistence/FileMapStoreFactory.java | 6 +-
.../dag/physical/StateTransitionCleanupTest.java | 207 ++++++++++++++++++
.../server/persistence/FileMapStoreTest.java | 76 ++++++-
.../checkpoint-storage-hdfs/pom.xml | 17 +-
.../EnvironmentCredentialConfigurationTest.java | 220 +++++++++++++++++++
.../engine/imap/storage/api/ExpirableValue.java | 70 ++++++
.../engine/imap/storage/api/IMapStorage.java | 47 ++++
.../imap-storage-plugins/imap-storage-file/pom.xml | 13 +-
.../engine/imap/storage/file/IMapFileStorage.java | 36 +++-
.../imap/storage/file/bean/IMapFileData.java | 9 +
.../engine/imap/storage/file/common/WALReader.java | 51 ++++-
.../imap/storage/file/IMapFileStorageTest.java | 25 +++
.../file/common/WALReaderAndWriterTest.java | 117 ++++++++++
.../EnvironmentCredentialConfigurationTest.java | 130 +++++++++++
112 files changed, 2903 insertions(+), 491 deletions(-)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/resources/{doris_source_no_schema.conf
=> fake_timestamp_tz_to_doris_zone_explicit.conf} (59%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/resources/{doris_source_no_schema.conf
=> fake_timestamp_tz_to_doris_zone_unset.conf} (61%)
create mode 100644
seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/junit/ContainerTestingExtensionTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-hdfs/src/test/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs/common/EnvironmentCredentialConfigurationTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-storage/imap-storage-api/src/main/java/org/apache/seatunnel/engine/imap/storage/api/ExpirableValue.java
create mode 100644
seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/test/java/org/apache/seatunnel/engine/imap/storage/file/config/EnvironmentCredentialConfigurationTest.java
