This is an automated email from the ASF dual-hosted git repository. lancelly pushed a commit to branch prepareInput in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a667d0c49e2e32b675259d61e434db9c58427f32 Author: lancelly <[email protected]> AuthorDate: Wed Oct 11 17:03:09 2023 +0800 set maxRuntime in UT --- .../execution/operator/process/AbstractConsumeAllOperator.java | 1 - .../java/org/apache/iotdb/db/queryengine/execution/DataDriverTest.java | 1 + 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AbstractConsumeAllOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AbstractConsumeAllOperator.java index c078bfb1308..8943d919209 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AbstractConsumeAllOperator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AbstractConsumeAllOperator.java @@ -176,7 +176,6 @@ public abstract class AbstractConsumeAllOperator extends AbstractOperator child.close(); } } - children.clear(); // friendly for gc inputTsBlocks = null; } diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/DataDriverTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/DataDriverTest.java index 31fbae023ca..10945c30158 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/DataDriverTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/DataDriverTest.java @@ -164,6 +164,7 @@ public class DataDriverTest { new SingleColumnMerger(new InputLocation(0, 0), new AscTimeComparator()), new SingleColumnMerger(new InputLocation(1, 0), new AscTimeComparator())), new AscTimeComparator()); + timeJoinOperator.getOperatorContext().setMaxRunTime(new Duration(500, TimeUnit.MILLISECONDS)); LimitOperator limitOperator = new LimitOperator(driverContext.getOperatorContexts().get(3), 250, timeJoinOperator);
