fix offset bug
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java index debd350..9ffafa7 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java
@@ -61,9 +61,8 @@ return null; } if (remainingOffset > 0) { - int offset = Math.min((int) remainingOffset, block.getPositionCount()); + int offset = (int) Math.min(remainingOffset, block.getPositionCount()); remainingOffset -= offset; - LOGGER.info("current remaining offset: {}", remainingOffset); return block.getRegion(offset, block.getPositionCount() - offset); } else { return block;