You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/04/11 11:56:58 UTC
[iotdb] branch FIDig updated: fix offset bug
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch FIDig
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/FIDig by this push:
new 18a05af730 fix offset bug
18a05af730 is described below
commit 18a05af7307543d037984fc010fb9850f8775198
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Apr 11 19:56:49 2023 +0800
fix offset bug
---
.../apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
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 debd350d10..9ffafa707f 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 @@ public class OffsetOperator implements ProcessOperator {
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;