This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch fix-offset-operator-test-null-tsblock in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 818fa7b6b8232d719a1d5cc807b4b4c8ff4d77af Author: Caideyipi <[email protected]> AuthorDate: Wed Jun 3 19:00:22 2026 +0800 Fix OffsetOperatorTest null TsBlock handling --- .../queryengine/execution/operator/OffsetOperatorTest.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/OffsetOperatorTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/OffsetOperatorTest.java index 526577d61bb..0d6e9a50be9 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/OffsetOperatorTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/OffsetOperatorTest.java @@ -169,6 +169,9 @@ public class OffsetOperatorTest { int count = 100; while (limitOperator.isBlocked().isDone() && limitOperator.hasNext()) { TsBlock tsBlock = limitOperator.next(); + if (tsBlock == null) { + continue; + } assertEquals(2, tsBlock.getValueColumnCount()); assertTrue(tsBlock.getColumn(0) instanceof IntColumn); assertTrue(tsBlock.getColumn(1) instanceof IntColumn); @@ -277,6 +280,9 @@ public class OffsetOperatorTest { int count = 0; while (offsetOperator.isBlocked().isDone() && offsetOperator.hasNext()) { TsBlock tsBlock = offsetOperator.next(); + if (tsBlock == null) { + continue; + } assertEquals(2, tsBlock.getValueColumnCount()); assertTrue(tsBlock.getColumn(0) instanceof IntColumn); assertTrue(tsBlock.getColumn(1) instanceof IntColumn); @@ -383,6 +389,9 @@ public class OffsetOperatorTest { while (offsetOperator.isBlocked().isDone() && offsetOperator.hasNext()) { TsBlock tsBlock = offsetOperator.next(); + if (tsBlock == null) { + continue; + } assertEquals(2, tsBlock.getValueColumnCount()); assertTrue(tsBlock.getColumn(0) instanceof IntColumn); assertTrue(tsBlock.getColumn(1) instanceof IntColumn); @@ -475,6 +484,9 @@ public class OffsetOperatorTest { while (offsetOperator.isBlocked().isDone() && offsetOperator.hasNext()) { TsBlock tsBlock = offsetOperator.next(); + if (tsBlock == null) { + continue; + } assertEquals(2, tsBlock.getValueColumnCount()); assertTrue(tsBlock.getColumn(0) instanceof IntColumn); assertTrue(tsBlock.getColumn(1) instanceof IntColumn);
