This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 65936d6e08 [Fix][Format] Preserve Avro field case during serialization
(#12009)
add c6b363af5c [Feature][Zeta] Add checkpoint completion benchmark (#12026)
No new revisions were added by this update.
Summary of changes:
docs/en/engines/zeta/benchmark.md | 23 +-
docs/zh/engines/zeta/benchmark.md | 21 +-
.../benchmark/CheckpointBenchmarkTrigger.java | 69 ++++
.../benchmark/CheckpointingTimeBenchmark.java | 66 ++++
.../CheckpointingTimeBenchmarkPipeline.java | 295 ++++++++++++++++
.../SeaTunnelCheckpointEnvironmentContext.java | 380 +++++++++++++++++++++
.../connector/source/BenchmarkSourceReader.java | 4 +-
...ml.template => engine-checkpoint.yaml.template} | 14 +-
.../hazelcast-checkpoint-master.yaml.template | 33 +-
.../hazelcast-checkpoint-worker.yaml.template | 25 +-
...mplate => source-sink-checkpoint.conf.template} | 32 +-
.../benchmark/CheckpointingTimeBenchmarkTest.java | 72 ++++
12 files changed, 985 insertions(+), 49 deletions(-)
create mode 100644
seatunnel-benchmarks/src/main/java/org/apache/seatunnel/benchmark/CheckpointBenchmarkTrigger.java
create mode 100644
seatunnel-benchmarks/src/main/java/org/apache/seatunnel/benchmark/CheckpointingTimeBenchmark.java
create mode 100644
seatunnel-benchmarks/src/main/java/org/apache/seatunnel/benchmark/CheckpointingTimeBenchmarkPipeline.java
create mode 100644
seatunnel-benchmarks/src/main/java/org/apache/seatunnel/benchmark/SeaTunnelCheckpointEnvironmentContext.java
copy
seatunnel-benchmarks/src/main/resources/benchmark/{engine-trace.yaml.template
=> engine-checkpoint.yaml.template} (80%)
copy
seatunnel-engine/seatunnel-engine-client/src/test/resources/hazelcast.yaml =>
seatunnel-benchmarks/src/main/resources/benchmark/hazelcast-checkpoint-master.yaml.template
(63%)
copy
seatunnel-engine/seatunnel-engine-common/src/test/resources/hazelcast.yaml =>
seatunnel-benchmarks/src/main/resources/benchmark/hazelcast-checkpoint-worker.yaml.template
(74%)
copy
seatunnel-benchmarks/src/main/resources/benchmark/{source-sink.conf.template =>
source-sink-checkpoint.conf.template} (62%)
create mode 100644
seatunnel-benchmarks/src/test/java/org/apache/seatunnel/benchmark/CheckpointingTimeBenchmarkTest.java
