Undo status fix

ivancea · ivancea · commit d5fb3946f3e0 · 2025-08-13T12:06:08.000+02:00
diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/AsyncOperator.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/AsyncOperator.java
@@ -238,7 +238,7 @@ public IsBlockedResult isBlocked() {
 
     @Override
     public final Operator.Status status() {
-        return status(checkpoint.getMaxSeqNo() + 1, checkpoint.getProcessedCheckpoint() + 1, processNanos.sum());
+        return status(Math.max(0L, checkpoint.getMaxSeqNo()), Math.max(0L, checkpoint.getProcessedCheckpoint()), processNanos.sum());
     }
 
     protected Operator.Status status(long receivedPages, long completedPages, long processNanos) {

Original file line number	Diff line number	Diff line change
`@@ -238,7 +238,7 @@ public IsBlockedResult isBlocked() {`
`238`	`238`
`239`	`239`	`@Override`
`240`	`240`	`public final Operator.Status status() {`
`241`		`- return status(checkpoint.getMaxSeqNo() + 1, checkpoint.getProcessedCheckpoint() + 1, processNanos.sum());`
	`241`	`+ return status(Math.max(0L, checkpoint.getMaxSeqNo()), Math.max(0L, checkpoint.getProcessedCheckpoint()), processNanos.sum());`
`242`	`242`	`}`
`243`	`243`
`244`	`244`	`protected Operator.Status status(long receivedPages, long completedPages, long processNanos) {`