fix: ignore situation with only on bound

apache · Jun 12, 2024 · 9d605b3 · 9d605b3
1 parent a1e2f8f
commit 9d605b3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...e/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java b/...e/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java
@@ -2112,6 +2112,9 @@ public static Pair<List<TTimePartitionSlot>, Pair<Boolean, Boolean>> getTimePart
 
   private static void reserveMemoryForTimePartitionSlot(
       long maxTime, long minTime, MPPQueryContext context) {
+    if (maxTime == Long.MAX_VALUE || minTime == Long.MIN_VALUE) {
+      return;
+    }
     long size = TimePartitionUtils.getEstimateTimePartitionSize(minTime, maxTime);
     context.reserveMemoryForFrontEnd(
         RamUsageEstimator.shallowSizeOfInstance(TTimePartitionSlot.class) * size);

diff --git a/...de/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/QueryTimePartitionTest.java b/...de/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/QueryTimePartitionTest.java
@@ -356,7 +356,7 @@ public void testTimeLtEqFilter() {
 
   @Test
   public void testGetTimePartitionSlotList() {
-    MPPQueryContext context = new MPPQueryContext(new QueryId("time-partition-test"));
+    MPPQueryContext context = new MPPQueryContext(new QueryId("time_partition_test"));
     // time >= 10 and time <= 9
     Pair<List<TTimePartitionSlot>, Pair<Boolean, Boolean>> res =
         getTimePartitionSlotList(