nzw921rx commented on code in PR #12418: URL: https://github.com/apache/seatunnel/pull/12418#discussion_r4060321176
########## seatunnel-benchmarks/README.md: ########## @@ -70,6 +70,36 @@ java -jar seatunnel-benchmarks/target/benchmarks.jar IMapDagStorageBenchmark java -jar seatunnel-benchmarks/target/benchmarks.jar IMapWalStorageBenchmark ``` +## Run the checkpoint scheduling benchmark + +```bash +java -jar seatunnel-benchmarks/target/benchmarks.jar CheckpointSchedulingBenchmark +``` + +`CheckpointSchedulingBenchmark` measures how long a due checkpoint trigger waits before its +scheduling thread runs it, as a distribution. This is separate from +`CheckpointingTimeBenchmark`, which measures checkpoint completion time: completion time is +dominated by the barrier round-trip and is close to blind to how the trigger was scheduled. + +Parameters: + +- `pipelineNum`: pipelines scheduling checkpoints on the member. Each `CheckpointCoordinator` + builds its own two-thread pool, so this also sets the scheduler thread count. +- `checkpointIntervalMillis`: interval of the background trigger load. The default is far below + the production default of 300000 so that a short iteration sees a realistic number of triggers. Review Comment: The benchmark testing document has been refactored and does not require any changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
