nzw921rx commented on PR #12418:
URL: https://github.com/apache/seatunnel/pull/12418#issuecomment-5777640326
@Vivek1106-04 I got a good idea about 2 using my chatgpt
I agree with the first option in point 2: use the minimum valid
`checkpointInterval` of 10 ms and set `checkpointMinPause` to `-1`.
The 10 ms interval can be isolated from the JMH result through
invocation-level setup:
```java
@Setup(Level.Invocation)
public void prepareInvocation() throws Exception {
awaitPreviousCheckpointCompleted();
// Cancel only the measured coordinator's automatically re-armed task.
cancelMeasuredCoordinatorTasks();
// Outside the measured region.
TimeUnit.MILLISECONDS.sleep(11);
// Arm the task-specific probe after the fixture is quiescent.
probe.arm();
}
```
JMH does not include `@Setup(Level.Invocation)` in the measured operation
time.
The measured region remains:
```text
scheduleTriggerPendingCheckpoint
→ real scheduler
→ tryTriggerPendingCheckpoint
→ state checks
→ coordinator lock
→ submission to executorService
```
The previous checkpoint completion, timer cleanup, and 10 ms interval wait
remain outside the measured result. Background coordinators can continue
running normally to preserve multi-pipeline scheduling load.
--
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]