This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch fix-audit-logger
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d22189ff3b3 fix
add 685141a6405 Fixed the bug that the attribute update container may add
extra calculated memory to schema engine (#16682)
add 69cda2da662 Add more optimizers for union (#16689)
add 2488001e808 SeriesScanUtil throws exception when using filters that
could not match any time range (#16691)
add 8420beaaf54 Fix wrong push limit down to AggTableScanNode (#16696)
add b6c6c7a1138 More robust IoTDBRegionReconstructForIoTV1IT (#16697)
add f096b8210ff Implemented the alter encoding compression function for
tree model (#16672)
add ababbf337e2 Support SSL-related parameters and interactive password
input in export/import tools (#16698)
add 4ebb89b91e8 implement the intersect (distinct | all ) for table model
(#16700)
add c406a81f53c Fix the error message of ConfigExecution (#16680)
add 9ae8233091f Fixed the null error message of fetch schema failed when
the regions is removing (#16713)
add a9ba7243ba9 Pipe: Fixed the NPE of commit interval (#16714)
add 3ec8979e42a Follow fix for encoding & compressor (#16712)
add 9d4c41092a8 Avoid unnecessary ssl error log caused by jdk bug (#16709)
add 2de3bb6f534 Active Load: Ignore java.io.UncheckedIOException
exceptions thrown during the file scanning process. (#16705)
add f67526420d0 Delete the tsfile and related attachments When only one
table and dat… (#16687)
add 639de5255ce Fixed the potential non-consistency caused by initialize
of DataNodeTableCache & Cleared the storageGroups in compatible codes (#16693)
add ffa9c562c4e Optimize the configuration logic of
dn_thrift_max_frame_size (#16724)
add b4d5b4235e1 Changed the SQL of AlterEncodingCompressor statement &
banned the "root" timeSeries & handled the empty intersection path & refactored
the IT (#16725)
add 8dbf2003cfd chore!: Bind real config address for Thrift and Raft
services (#16717)
add 93b2d1fe999 Make ErrMsg more readable when the predicate has too many
conjunctions because of too many devices #16715
add 93c55577e6f Pipe: Fix unhandled timeout exceptions in Thrift Client
(#16727)
add 468a91a4d2e Fixed the procedure has_more_state bug & Fixed the IT for
encoding & compressor (#16729)
add a6e8493bfc0 Optimized the lock for encoding & compressor's invalidate
cache (#16733)
add d48347cdc8d Pipe: support path exclusion under tree model (#16632)
add 43b89b9a480 Change the privilege of showVersionStatement #16736
add 49c625bb83e [AINode] Package AINode via PyInstaller (#16707)
add 96e8681dd51 Support the JDBC client to prevent SQL injection (#16734)
add b7f9f8d49af Fix that a deletion test may fail due to inconsistency
caused by leader redistribution (#16744)
add 7515568c8e4 Fixed the NPE caused by concurrent "check for
createTimeSeries" and deleteTimeSeries (#16742)
add 6e8748e0256 Pipe: Optimized the default behavior in meta sync for
retries to wait for other regions (#16740)
add f608a2d2e6a Adjust the exception message cause by the WHERE clause,
which uses a range comparison on the same field, specifically when the left
value of the range is greater than the right value of the range. (#16741)
add e53d27c0ad0 Pipe: Trimmed some of the pipe logs (#16747)
add db7c801d846 Active Load: Fixes errors caused by Load copying resource
files. (#16753)
add a6191d916b2 Pipe: Modify the Pipe configuration item log name to be
consistent with the Properties name. (#16732)
add 91e48f07f63 feat: encode load attributes in active load directories
(#16722)
add 8e7ed04e637 Merge remote-tracking branch 'upstream/master' into
fix-audit-logger
add 7fb2c096378 fix
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d1a.yml | 2 +-
integration-test/src/assembly/mpp-test.xml | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 25 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 14 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 62 +--
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 31 +-
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 66 +--
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 2 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 8 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 2 +-
.../it/partition/IoTDBPartitionCreationIT.java | 4 +-
.../it/partition/IoTDBPartitionDurableIT.java | 4 +-
.../it/partition/IoTDBPartitionGetterIT.java | 41 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 1 +
.../confignode/it/utils/ConfigNodeTestUtils.java | 16 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 21 +
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 4 +-
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 14 +
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 5 +-
.../iotdb/db/it/IoTDBLoadTsFileWithModIT.java | 60 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 8 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 2 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 2 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 3 +-
.../it/auth/IoTDBSystemPermissionRelationalIT.java | 3 +-
.../apache/iotdb/db/it/path/IoTDBQuotedPathIT.java | 4 +-
.../it/schema/IoTDBAlterEncodingCompressorIT.java | 209 +++++++
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 14 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 2 +-
.../db/it/schema/IoTDBDeleteTimeSeriesIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 2 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 2 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 616 ++++++++++++---------
.../treemodel/manual/IoTDBPipeInclusionIT.java | 89 ++-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 374 +++++++++++++
.../it/query/old/IoTDBSimpleQueryTableIT.java | 2 +-
...nionTableIT.java => IoTDBIntersectTableIT.java} | 78 +--
.../it/query/recent/IoTDBMaintainAuthIT.java | 8 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 24 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 22 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 6 +-
.../org/apache/iotdb/tool/common/Constants.java | 12 +
.../org/apache/iotdb/tool/common/OptionsUtil.java | 30 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 41 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 10 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 29 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 10 +-
.../org/apache/iotdb/tool/data/ImportDataTree.java | 10 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 43 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 10 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 12 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 10 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 10 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 17 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 154 +++++-
.../iotdb/rpc/NettyTNonblockingTransport.java | 9 +-
.../rpc/TCompressedElasticFramedTransport.java | 8 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 119 ++--
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
iotdb-core/ainode/.gitignore | 6 +-
iotdb-core/ainode/ainode.spec | 199 +++++++
iotdb-core/ainode/ainode.xml | 17 +-
iotdb-core/ainode/build_binary.py | 596 ++++++++++++++++++++
iotdb-core/ainode/iotdb/ainode/core/config.py | 28 +-
iotdb-core/ainode/iotdb/ainode/core/constant.py | 18 +-
.../iotdb/ainode/core/inference/pool_controller.py | 47 +-
.../pool_scheduler/basic_pool_scheduler.py | 7 +-
iotdb-core/ainode/iotdb/ainode/core/log.py | 4 +-
iotdb-core/ainode/iotdb/ainode/core/script.py | 80 +--
iotdb-core/ainode/poetry.lock | 111 +++-
iotdb-core/ainode/pom.xml | 92 +--
iotdb-core/ainode/pyproject.toml | 29 +-
.../ainode/resources/syncPythonVersion.groovy | 33 --
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
.../write/database/PreDeleteDatabasePlan.java | 22 +-
.../payload/PipeAlterEncodingCompressorPlan.java | 130 +++++
.../iotdb/confignode/manager/ConfigManager.java | 46 +-
.../apache/iotdb/confignode/manager/IManager.java | 19 +-
.../iotdb/confignode/manager/ProcedureManager.java | 68 +++
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 69 ++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 11 +
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 6 +-
.../pipe/source/ConfigRegionListeningFilter.java | 3 +
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
.../source/PipeConfigTreePatternParseVisitor.java | 69 ++-
.../manager/schema/ClusterSchemaManager.java | 26 +-
.../persistence/executor/ConfigPlanExecutor.java | 1 +
.../persistence/partition/PartitionInfo.java | 2 +-
.../schema/AlterEncodingCompressorProcedure.java | 337 +++++++++++
.../impl/schema/DataNodeTSStatusTaskExecutor.java | 74 +++
.../impl/schema/DeactivateTemplateProcedure.java | 26 +-
.../impl/schema/DeleteDatabaseProcedure.java | 28 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 26 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 49 +-
.../table/AbstractAlterOrDropTableProcedure.java | 29 +-
...tate.java => AlterEncodingCompressorState.java} | 7 +-
...ageGroupState.java => DeleteDatabaseState.java} | 2 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../PipeConfigTreePatternParseVisitorTest.java | 7 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 28 +
...a => AlterEncodingCompressorProcedureTest.java} | 26 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 1 +
.../assembly/resources/conf/logback-datanode.xml | 15 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 -
.../schemaregion/SchemaExecutionVisitor.java | 15 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../agent/task/connection/PipeEventCollector.java | 4 +-
.../parser/TsFileInsertionEventParserProvider.java | 6 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 23 +-
.../visitor/PipeStatementTSStatusVisitor.java | 42 +-
.../PipeStatementTreePatternParseVisitor.java | 22 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 24 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 6 +-
.../source/dataregion/IoTDBDataRegionSource.java | 6 +-
.../realtime/assigner/DisruptorQueue.java | 4 +-
.../PipePlanTreePatternParseVisitor.java | 41 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 95 +++-
.../execution/executor/RegionReadExecutor.java | 10 +-
.../execution/operator/source/SeriesScanUtil.java | 5 +
.../queryengine/plan/analyze/PredicateUtils.java | 16 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 13 +-
.../plan/execution/config/ConfigExecution.java | 16 +-
.../execution/config/TableConfigTaskVisitor.java | 1 -
.../execution/config/TreeConfigTaskVisitor.java | 9 +
.../config/executor/ClusterConfigTaskExecutor.java | 62 +++
.../config/executor/IConfigTaskExecutor.java | 4 +
...eTask.java => AlterEncodingCompressorTask.java} | 17 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 101 +++-
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 8 +
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../write/AlterEncodingCompressorNode.java | 146 +++++
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 6 +-
.../plan/relational/planner/RelationPlanner.java | 24 +-
.../distribute/TableDistributedPlanGenerator.java | 2 +-
.../iterative/rule/ImplementIntersectAll.java | 95 ++++
.../rule/ImplementIntersectDistinctAsUnion.java | 88 +++
.../iterative/rule/PruneDistinctAggregation.java | 9 +
.../rule/PushDownOffsetIntoTableScan.java | 4 +-
...thMergeSort.java => PushLimitThroughUnion.java} | 82 +--
.../iterative/rule/PushProjectionThroughUnion.java | 111 ++++
.../iterative/rule/PushTopKThroughUnion.java | 102 ++++
.../iterative/rule/RemoveEmptyUnionBranches.java | 113 ++++
.../iterative/rule/SetOperationNodeTranslator.java | 355 ++++++++++++
.../planner/node/AggregationTableScanNode.java | 10 +
...nforceSingleRowNode.java => IntersectNode.java} | 58 +-
.../plan/relational/planner/node/Patterns.java | 22 +-
.../optimizations/LogicalOptimizeFactory.java | 37 +-
.../PushLimitOffsetIntoTableScan.java | 2 +-
.../optimizations/UnaliasSymbolReferences.java | 31 ++
.../security/TreeAccessCheckVisitor.java | 56 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 6 +
.../plan/statement/crud/LoadTsFileStatement.java | 16 +-
.../metadata/AlterEncodingCompressorStatement.java | 126 +++++
.../schemaengine/schemaregion/ISchemaRegion.java | 8 +-
.../schemaregion/SchemaRegionPlanType.java | 2 +
.../schemaregion/SchemaRegionPlanVisitor.java | 6 +
.../update/DeviceAttributeCacheUpdater.java | 8 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 43 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 14 +-
.../visitor/SchemaRegionPlanDeserializer.java | 7 +
.../visitor/SchemaRegionPlanSerializer.java | 8 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 111 ++--
.../schemaengine/schemaregion/utils/MetaUtils.java | 6 +-
.../write/req/SchemaRegionWritePlanFactory.java | 3 +
.../db/schemaengine/table/DataNodeTableCache.java | 17 +
.../db/storageengine/dataregion/DataRegion.java | 121 +++-
.../dataregion/read/QueryDataSource.java | 5 +
.../load/active/ActiveLoadDirScanner.java | 26 +-
.../load/active/ActiveLoadPathHelper.java | 282 ++++++++++
.../load/active/ActiveLoadPendingQueue.java | 17 +-
.../load/active/ActiveLoadTsFileLoader.java | 36 +-
.../storageengine/load/active/ActiveLoadUtil.java | 39 +-
.../load/config/LoadTsFileConfigurator.java | 18 +
.../db/pipe/pattern/TreePatternCoverageTest.java | 133 +++++
.../PipeStatementTreePatternParseVisitorTest.java | 202 ++++---
.../PipePlanTreePatternParseVisitorTest.java | 7 +-
.../plan/relational/analyzer/IntersectTest.java | 121 ++++
...{MergeUnionTest.java => UnionOptimizeTest.java} | 62 ++-
.../conf/iotdb-system.properties.template | 4 +-
.../apache/iotdb/commons/client/ThriftClient.java | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 127 +++--
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../iotdb/commons/exception/MetadataException.java | 2 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 7 +
.../apache/iotdb/commons/path/PathPatternTree.java | 13 +-
.../task/progress/interval/PipeCommitInterval.java | 4 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 51 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 31 +-
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../datastructure/pattern/IoTDBTreePattern.java | 68 ++-
.../pattern/IoTDBTreePatternOperations.java | 52 ++
.../datastructure/pattern/PrefixTreePattern.java | 70 ++-
.../datastructure/pattern/SingleTreePattern.java | 59 --
.../pipe/datastructure/pattern/TreePattern.java | 369 ++++++++++--
.../pattern/UnionIoTDBTreePattern.java | 115 ++--
.../datastructure/pattern/UnionTreePattern.java | 17 +-
.../pattern/WithExclusionIoTDBTreePattern.java | 213 +++++++
.../pattern/WithExclusionTreePattern.java | 119 ++++
.../commons/pipe/receiver/IoTDBFileReceiver.java | 6 +
.../pipe/receiver/PipeReceiverStatusHandler.java | 18 +-
.../pipe/sink/client/IoTDBClientManager.java | 5 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 3 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 6 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 14 +-
.../schema/table/NonCommittableTsTable.java} | 36 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 24 +-
.../service/AbstractThriftServiceThread.java | 15 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 18 +
.../pipe/datastructure/PipeCommitQueueTest.java | 2 +
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +-
.../src/main/thrift/confignode.thrift | 12 +
.../src/main/thrift/datanode.thrift | 14 +
scripts/conf/ainode-env.sh | 138 -----
scripts/conf/windows/ainode-env.bat | 129 -----
scripts/sbin/start-ainode.sh | 41 +-
scripts/sbin/windows/start-ainode.bat | 48 +-
242 files changed, 7905 insertions(+), 2255 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBAlterEncodingCompressorIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBUnionTableIT.java
=> IoTDBIntersectTableIT.java} (62%)
create mode 100644 iotdb-core/ainode/ainode.spec
create mode 100644 iotdb-core/ainode/build_binary.py
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterEncodingCompressorPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeTSStatusTaskExecutor.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RemoveAINodeState.java
=> AlterEncodingCompressorState.java} (91%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteStorageGroupState.java
=> DeleteDatabaseState.java} (96%)
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/{table/view/DropViewProcedureTest.java
=> AlterEncodingCompressorProcedureTest.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowDatabaseTask.java
=> AlterEncodingCompressorTask.java} (68%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/AlterEncodingCompressorNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/ImplementIntersectAll.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/ImplementIntersectDistinctAsUnion.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{MergeLimitOverProjectWithMergeSort.java
=> PushLimitThroughUnion.java} (57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PushProjectionThroughUnion.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PushTopKThroughUnion.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/RemoveEmptyUnionBranches.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SetOperationNodeTranslator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{EnforceSingleRowNode.java
=> IntersectNode.java} (57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelper.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/TreePatternCoverageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/IntersectTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{MergeUnionTest.java
=> UnionOptimizeTest.java} (64%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/IoTDBTreePatternOperations.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/SingleTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionIoTDBTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionTreePattern.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/state/CountState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/table/NonCommittableTsTable.java}
(60%)
delete mode 100644 scripts/conf/ainode-env.sh
delete mode 100644 scripts/conf/windows/ainode-env.bat
