This is an automated email from the ASF dual-hosted git repository. chenyz pushed a commit to branch udtf-optimize in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a8a5486f67aa33214fad79333ba0c7570de66a76 Author: Chen YZ <[email protected]> AuthorDate: Sat Feb 22 21:19:05 2025 +0800 refactor --- .../src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java | 8 ++++---- .../planner/distribute/TableDistributedPlanGenerator.java | 7 +++++-- 2 files changed, 9 insertions(+), 6 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java index 05c36271e60..ae88050e4a8 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java @@ -437,16 +437,16 @@ public class IoTDBConfig { private int avgSeriesPointNumberThreshold = 100000; /** Enable inner space compaction for sequence files */ - private volatile boolean enableSeqSpaceCompaction = true; + private volatile boolean enableSeqSpaceCompaction = false; /** Enable inner space compaction for unsequence files */ - private volatile boolean enableUnseqSpaceCompaction = true; + private volatile boolean enableUnseqSpaceCompaction = false; /** Compact the unsequence files into the overlapped sequence files */ - private volatile boolean enableCrossSpaceCompaction = true; + private volatile boolean enableCrossSpaceCompaction = false; /** Enable auto repair compaction */ - private volatile boolean enableAutoRepairCompaction = true; + private volatile boolean enableAutoRepairCompaction = false; /** The buffer for sort operation */ private long sortBufferSize = 1024 * 1024L; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java index 49b1bf790fb..501a5b9c1a1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java @@ -576,10 +576,13 @@ public class TableDistributedPlanGenerator .max(Comparator.comparingInt(Map.Entry::getValue)) .map(Map.Entry::getKey) .orElse(null); - if(!crossRegionDevices.isEmpty()) { + if (!crossRegionDevices.isEmpty()) { node.setDeviceEntries(crossRegionDevices); result.add( - new CollectNode(queryId.genPlanNodeId(), constructDeviceTableScanByRegionReplicaSet(node, context), node.getOutputSymbols())); + new CollectNode( + queryId.genPlanNodeId(), + constructDeviceTableScanByRegionReplicaSet(node, context), + node.getOutputSymbols())); } return result; }
