diff --git a/core/src/main/java/org/opensearch/sql/planner/physical/LimitOperator.java b/core/src/main/java/org/opensearch/sql/planner/physical/LimitOperator.java index 168a730958..227419e7b1 100644 --- a/core/src/main/java/org/opensearch/sql/planner/physical/LimitOperator.java +++ b/core/src/main/java/org/opensearch/sql/planner/physical/LimitOperator.java @@ -58,9 +58,7 @@ public void open() { @Override public boolean hasNext() { - var inNext = input.hasNext(); - var cond = count < offset + limit; - return inNext && cond; + return input.hasNext() && count < offset + limit; } @Override