nzw921rx commented on PR #12165:
URL: https://github.com/apache/seatunnel/pull/12165#issuecomment-6341719390
p1.00: 161.792 us/op
Iteration 5: # measured 100 of 100 due triggers; skipped 0 with a
checkpoint already pending before the due time, 0 that came due while another
trigger was being measured, 0 where parking overran the due time, 0 that ran
before their estimated due time
Error: Exception in thread "checkpoint-dispatcher-7"
java.util.concurrent.RejectedExecutionException: Task
java.util.concurrent.CompletableFuture$AsyncSupply@6dd9c171 rejected from
java.util.concurrent.ThreadPoolExecutor@3a11373d[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 49223]
at
java.base/java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2055)
at
java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
at
java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
at
java.base/java.util.concurrent.CompletableFuture.asyncSupplyStage(CompletableFuture.java:1714)
at
java.base/java.util.concurrent.CompletableFuture.supplyAsync(CompletableFuture.java:1937)
at
org.apache.seatunnel.engine.common.utils.concurrent.CompletableFuture.supplyAsync(CompletableFuture.java:117)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.createPendingCheckpoint(CheckpointCoordinator.java:1090)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.tryTriggerPendingCheckpoint(CheckpointCoordinator.java:847)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.lambda$scheduleTriggerPendingCheckpoint$5(CheckpointCoordinator.java:573)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at
org.apache.seatunnel.engine.server.checkpoint.scheduler.PipelineCheckpointTask.run(PipelineCheckpointTask.java:96)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Error: Exception in thread "checkpoint-dispatcher-0"
java.util.concurrent.RejectedExecutionException: Task
java.util.concurrent.CompletableFuture$AsyncSupply@771dd584 rejected from
java.util.concurrent.ThreadPoolExecutor@3a11373d[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 49223]
at
java.base/java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2055)
at
java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
at
java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
at
java.base/java.util.concurrent.CompletableFuture.asyncSupplyStage(CompletableFuture.java:1714)
at
java.base/java.util.concurrent.CompletableFuture.supplyAsync(CompletableFuture.java:1937)
at
org.apache.seatunnel.engine.common.utils.concurrent.CompletableFuture.supplyAsync(CompletableFuture.java:117)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.createPendingCheckpoint(CheckpointCoordinator.java:1090)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.tryTriggerPendingCheckpoint(CheckpointCoordinator.java:847)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.lambda$scheduleTriggerPendingCheckpoint$5(CheckpointCoordinator.java:573)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at
org.apache.seatunnel.engine.server.checkpoint.scheduler.PipelineCheckpointTask.run(PipelineCheckpointTask.java:96)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Shared scheduling is a benchmark test where there are definite row errors
--
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]
