This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch force_ci/object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0657671d20f Avoid unnecessary ssl error log caused by jdk bug (#16709)
new cbe57655b1e Active Load: Ignore java.io.UncheckedIOException
exceptions thrown during the file scanning process. (#16705)
new 3a8d6d52788 Delete the tsfile and related attachments When only one
table and dat… (#16687)
new 602d4650aaf Fixed the potential non-consistency caused by initialize
of DataNodeTableCache & Cleared the storageGroups in compatible codes (#16693)
new ce054e88e2f Optimize the configuration logic of
dn_thrift_max_frame_size (#16724)
new 6f47cca0efb Changed the SQL of AlterEncodingCompressor statement &
banned the "root" timeSeries & handled the empty intersection path & refactored
the IT (#16725)
new 26b5ae3bb18 chore!: Bind real config address for Thrift and Raft
services (#16717)
new a3807d28426 Make ErrMsg more readable when the predicate has too many
conjunctions because of too many devices #16715
new d24cddadbd2 Pipe: Fix unhandled timeout exceptions in Thrift Client
(#16727)
new 15f39d48543 Fixed the procedure has_more_state bug & Fixed the IT for
encoding & compressor (#16729)
new 8a3dbcb7db4 Optimized the lock for encoding & compressor's invalidate
cache (#16733)
new 25d5ba55135 Pipe: support path exclusion under tree model (#16632)
new f19824d287b Change the privilege of showVersionStatement #16736
new ff6f7a26ccf [AINode] Package AINode via PyInstaller (#16707)
new 4e1df942a49 Support the JDBC client to prevent SQL injection (#16734)
new a1fe4104c9d Fix that a deletion test may fail due to inconsistency
caused by leader redistribution (#16744)
new d712ffc4d5f Fixed the NPE caused by concurrent "check for
createTimeSeries" and deleteTimeSeries (#16742)
new 92878f4ad93 Pipe: Optimized the default behavior in meta sync for
retries to wait for other regions (#16740)
new 197c4f18af9 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)
new 401c5e9208e Pipe: Trimmed some of the pipe logs (#16747)
new 43c0320204d Active Load: Fixes errors caused by Load copying resource
files. (#16753)
new 8fe93f2d622 Pipe: Modify the Pipe configuration item log name to be
consistent with the Properties name. (#16732)
new b396766f4f2 feat: encode load attributes in active load directories
(#16722)
new 3a6c3bbce54 [AINode] Enable AINode start as background (-d) (#16762)
new 71976f5ba5e fix (#16702)
new 104bcf1eb4f reduce error log when compaction service is stopped & fix
bugs (#16756)
new dfda7a0b221 [AINode] Update AINodeClient for DataNode to borrow
(#16647)
new 08c0eec5a91 [AINode] Fix bug that AINode cannot compile in Windows
(#16767)
new 2078b4f706d fix (#16773)
new c110ab10c03 Load: Fixed the bug that mods is not deleted in load
tsFile when there are exceptions & Fixed the potential NPE in air gap agent
close() method (#16775)
new 81b6d592251 [AINode] Fix bug of sundial and forecast udf (#16768)
new 842c4a5ffc8 Fixed the bugs related to device auto-create alignment
ignorance (#16780)
new fe49c5ee080 Load: Active Load supports ModV2 (#16769)
new 769f10374dd Load: Fixed the issue of TSFile parent directory being
null and TSFile resource being updated during the Load process. (#16751)
new e72ee9a247a Load: Fixed parameter passing error in MoveFile function
(#16748)
new 40355e34103 Refine CN consensus layer API for procedure robustness
(#16303)
new b7e1c02338f Pipe: improved the memory calculation for tablets (#16739)
new 50dd71436ec Fixed the bug related to "Fixed the bugs related to device
auto-create alignment ignorance" (#16781)
new 9488a7ed0e6 Load: Remove the getParentFile and exists checks from Load
New File (#16787)
new ccf4346314e Optimized the error message when the column is not
tag/attribute in device related SQLs (#16750)
new e54b8a90ce3 Avoid connection reset error log printed (#16797)
new 60e8c6352c3 Fix that settle compaction may lgnore some newly incoming
deletions (#16799)
new 45823164d0f Fix slowQueryThreshold & optimize encodeBatch (#16765)
new e34e0fcb929 Pipe: Adjusted the waiting time of temporary unavailable
exceptions (#16798)
new a1b2287f91e [AINode] Delete poetry.lock for easier maintain different
operating systems (#16793)
new 1b2d3ffcff0 Bump ratis to apache 3.2.1 (#16801)
The 45 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/cluster-it-1c1d1a.yml | 2 +-
dependencies.json | 14 +-
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 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 16 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 21 +
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 5 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 145 ++
.../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 | 44 +-
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 14 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 22 +
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 8 +
.../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 | 88 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 380 +++-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 2 +-
.../it/query/recent/IoTDBMaintainAuthIT.java | 8 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 44 +-
.../it/session/IoTDBSessionRelationalIT.java | 2 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 22 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 6 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 17 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 154 +-
.../rpc/TCompressedElasticFramedTransport.java | 8 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 104 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +-
iotdb-core/ainode/.gitignore | 9 +-
iotdb-core/ainode/ainode.spec | 199 ++
iotdb-core/ainode/ainode.xml | 17 +-
iotdb-core/ainode/build_binary.py | 602 ++++++
iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 10 +-
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 | 49 +-
.../pool_scheduler/basic_pool_scheduler.py | 7 +-
iotdb-core/ainode/iotdb/ainode/core/log.py | 4 +-
.../iotdb/ainode/core/manager/inference_manager.py | 4 +-
.../ainode/core/model/sundial/modeling_sundial.py | 13 +-
.../ainode/core/model/timerxl/modeling_timer.py | 6 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 2 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 1 +
iotdb-core/ainode/iotdb/ainode/core/script.py | 80 +-
iotdb-core/ainode/poetry.lock | 2226 --------------------
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 | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
iotdb-core/confignode/pom.xml | 2 +-
.../async/AsyncAINodeHeartbeatClientPool.java | 7 +-
.../request/read/model/ShowModelPlan.java | 4 +-
.../write/database/PreDeleteDatabasePlan.java | 22 +-
.../iotdb/confignode/manager/ConfigManager.java | 54 +-
.../apache/iotdb/confignode/manager/IManager.java | 34 +-
.../iotdb/confignode/manager/ModelManager.java | 37 +-
.../iotdb/confignode/manager/ProcedureManager.java | 27 +
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 6 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 13 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 46 +-
.../manager/schema/ClusterSchemaManager.java | 26 +-
.../persistence/partition/PartitionInfo.java | 2 +-
.../procedure/CompletedProcedureRecycler.java | 21 +-
.../iotdb/confignode/procedure/Procedure.java | 27 +-
.../confignode/procedure/ProcedureExecutor.java | 88 +-
.../procedure/TimeoutExecutorThread.java | 12 +-
.../procedure/impl/model/CreateModelProcedure.java | 4 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 4 +-
.../schema/AlterEncodingCompressorProcedure.java | 11 +-
.../impl/schema/DeleteDatabaseProcedure.java | 28 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 7 +-
...ageGroupState.java => DeleteDatabaseState.java} | 2 +-
.../procedure/store/ConfigProcedureStore.java | 26 +-
.../procedure/store/IProcedureStore.java | 10 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 69 +-
...figPhysicalPlanTreePatternParseVisitorTest.java | 7 +-
iotdb-core/consensus/pom.xml | 14 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 1 +
iotdb-core/datanode/pom.xml | 2 +-
.../assembly/resources/conf/logback-datanode.xml | 15 -
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 -
.../schemaregion/SchemaExecutionVisitor.java | 44 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../agent/task/connection/PipeEventCollector.java | 4 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 4 +-
.../parser/TsFileInsertionEventParserProvider.java | 6 +-
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 25 +-
.../visitor/PipeStatementTSStatusVisitor.java | 42 +-
.../PipeStatementTreePatternParseVisitor.java | 22 +-
...leStatementDataTypeConvertExecutionVisitor.java | 4 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 55 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 62 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 18 +-
.../source/dataregion/IoTDBDataRegionSource.java | 6 +-
.../realtime/assigner/DisruptorQueue.java | 4 +-
.../PipePlanTreePatternParseVisitor.java | 41 +-
.../db/protocol/client/AINodeClientFactory.java | 133 ++
.../iotdb/db/protocol/client/ConfigNodeClient.java | 51 +-
.../db/protocol}/client/ainode/AINodeClient.java | 168 +-
.../client/ainode/AINodeClientManager.java | 75 +
.../client/ainode/AsyncAINodeServiceClient.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 59 +-
.../execution/executor/RegionWriteExecutor.java | 4 +-
.../operator/process/ai/InferenceOperator.java | 4 +-
.../InformationSchemaContentSupplierFactory.java | 17 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../queryengine/plan/analyze/PredicateUtils.java | 16 +-
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 14 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 4 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 51 +-
.../execution/config/TableConfigTaskVisitor.java | 1 -
.../execution/config/TreeConfigTaskVisitor.java | 3 +-
.../config/executor/ClusterConfigTaskExecutor.java | 114 +-
.../config/metadata/ai/ShowAIDevicesTask.java | 2 +-
.../config/metadata/ai/ShowLoadedModelsTask.java | 4 +-
.../config/metadata/ai/ShowModelsTask.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 33 +-
.../plan/node/load/LoadSingleTsFileNode.java | 6 +-
.../relational/analyzer/StatementAnalyzer.java | 51 +-
.../function/tvf/ForecastTableFunction.java | 8 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 6 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 2 +-
.../cache/TableDeviceSchemaCacheMetrics.java | 9 +-
.../security/TreeAccessCheckVisitor.java | 4 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 12 +-
.../plan/statement/StatementVisitor.java | 2 +-
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 18 +-
.../statement/metadata/CountDatabaseStatement.java | 2 +-
.../db/queryengine/plan/udf/UDTFForecast.java | 9 +-
.../rescon/MemSchemaEngineStatistics.java | 3 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 5 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 16 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 16 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 96 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 21 +-
.../schemaengine/schemaregion/utils/MetaUtils.java | 6 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 10 +
.../write/req/impl/CreateTimeSeriesPlanImpl.java | 10 +
.../db/schemaengine/table/DataNodeTableCache.java | 17 +
.../db/storageengine/dataregion/DataRegion.java | 123 +-
.../execute/task/AbstractCompactionTask.java | 3 +-
.../execute/task/InnerSpaceCompactionTask.java | 14 +-
.../execute/task/SettleCompactionTask.java | 4 +
.../dataregion/tsfile/TsFileResource.java | 43 +-
.../db/storageengine/load/LoadTsFileManager.java | 14 +
.../load/active/ActiveLoadDirScanner.java | 46 +-
.../load/active/ActiveLoadPathHelper.java | 282 +++
.../load/active/ActiveLoadPendingQueue.java | 17 +-
.../load/active/ActiveLoadTsFileLoader.java | 42 +-
.../load/config/LoadTsFileConfigurator.java | 18 +
...leStatementDataTypeConvertExecutionVisitor.java | 10 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 10 +-
.../db/storageengine/load/disk/MinIOSelector.java | 10 +-
.../ActiveLoadUtil.java => util/LoadUtil.java} | 88 +-
.../db/utils/datastructure/AlignedTVList.java | 16 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../db/metadata/path/MeasurementPathTest.java | 4 +-
.../db/pipe/pattern/TreePatternCoverageTest.java | 133 ++
.../PipeStatementTreePatternParseVisitorTest.java | 202 +-
.../PipePlanTreePatternParseVisitorTest.java | 7 +-
.../compaction/utils/CompactionTestFileWriter.java | 6 +-
.../memtable/AlignedTVListIteratorTest.java | 57 +
iotdb-core/node-commons/pom.xml | 8 +-
.../conf/iotdb-system.properties.template | 4 +-
.../iotdb/commons/client/ClientPoolFactory.java | 52 -
.../apache/iotdb/commons/client/ThriftClient.java | 3 +-
.../commons/client/ainode/AINodeClientManager.java | 40 -
.../apache/iotdb/commons/conf/CommonConfig.java | 156 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../apache/iotdb/commons/path/MeasurementPath.java | 26 -
.../org/apache/iotdb/commons/path/PartialPath.java | 26 +
.../task/subtask/PipeAbstractSinkSubtask.java | 13 +
.../iotdb/commons/pipe/config/PipeConfig.java | 61 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 42 +-
.../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 ++
.../pipe/receiver/PipeReceiverStatusHandler.java | 152 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 14 +-
.../schema/table/NonCommittableTsTable.java} | 36 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 24 +-
.../service/AbstractThriftServiceThread.java | 15 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 92 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 59 +-
.../commons/pipe/task/PipeSleepIntervalTest.java | 83 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 79 +
.../src/main/thrift/confignode.thrift | 83 +-
.../src/main/thrift/datanode.thrift | 1 +
pom.xml | 16 +-
scripts/conf/ainode-env.sh | 138 --
scripts/conf/windows/ainode-env.bat | 129 --
scripts/sbin/start-ainode.sh | 56 +-
scripts/sbin/windows/start-ainode.bat | 62 +-
236 files changed, 6294 insertions(+), 5080 deletions(-)
create mode 100644 iotdb-core/ainode/ainode.spec
create mode 100644 iotdb-core/ainode/build_binary.py
delete mode 100644 iotdb-core/ainode/poetry.lock
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteStorageGroupState.java
=> DeleteDatabaseState.java} (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/AINodeClientFactory.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons =>
datanode/src/main/java/org/apache/iotdb/db/protocol}/client/ainode/AINodeClient.java
(74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ainode/AINodeClientManager.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons =>
datanode/src/main/java/org/apache/iotdb/db/protocol}/client/ainode/AsyncAINodeServiceClient.java
(98%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelper.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/{active/ActiveLoadUtil.java
=> util/LoadUtil.java} (61%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/TreePatternCoverageTest.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClientManager.java
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%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/PipeSleepIntervalTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/FileUtilsTest.java
delete mode 100644 scripts/conf/ainode-env.sh
delete mode 100644 scripts/conf/windows/ainode-env.bat