This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch udsf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 736b709c45c add ut and fix it
add 7fb82cf4377 save
add 7806f84debe Pipe: Allow STATEMENT_STATUS_VISITOR and
STATEMENT_EXCEPTION_VISITOR for data conversion statements on data sync
receiver side (#14220)
add aaa9a9b86e3 Fixed the bug that a pre-updated table may face multiple
updates and generate NPE
add 8c6bd8e6c15 Fix that queries may retrieve false positive deletion
add 196795d61f7 Fix async recover TsfileResource error handle
add 355abf59902 Refactor TableSession and TableSessionPool of Python
client (#14232)
add 87dc2ca7245 Tsfile java interfaces & Subscription: The usage of bitmap
in SubscriptionSessionDataSet may cause npe (#14124)
add 6eb576cc9fb Pipe IT: Modify the forwarding-pipe-requests configuration
of Double Living IT (#14240)
add 642cf54930b Fix that table deletion will be mistakenly merged together
add 05bc4fd7f1d Some files were not added to TsFileResourceManager
add c5eacf01e8f Fix error in single device with sort + offset + limit
align by device query
add 041d292b092 [remove datanode] Do not disable the entire region group
for one removing region (#14241)
add 45d189e1317 Disabled some unsupportted operations
add 1e93245b822 Diasble delete-from sql
add 2f51c3b205d Add table series number in schema quota
add 7af7c80c551 Implement schema quota check at schemaRegion for table
device
add db715b76b1e Combine CSV SQL TSfile data import/export script (#13930)
(#14191)
add 9cffb76310d Fix the deserialization of table deletion in WAL
add eece66eec7d Fixed the bug that drop table won't release device num in
quota & table requests may block forever after ConfigNode restart
add 496c62e1819 Enhance procedure recover policy
add 73476e00a9a Fix back-quote remove of Select-Into query when query is
not for raw data
add d101d76879c [remove datanode] Not re-submit region migration procedure
when leader change or reboot #14277
add ba2646059ea Pipe: Introduce restart strategy to control resources'
memory only used by pipe hardlinked files (#14279)
add 72e69aee1f9 [Refactor] Reduce redundancy by introducing consistent
functional interface in SessionConnection (#14212)
add 2bad1f7477f Pipe: Enhanced the pipe transferred create timeseries
logic to allow merging tags / attributes (#14261)
add 6e9aa8ee50d Pipe: Fix a tree model pipe becomes table model pipe
exceptionally due to alter pipe operations (#14242)
add 2aa7af9599a Common Config & Pipe IT: Fixed the bug that
dn-connection-timeout and cn-connection-timeout are mixed (#14275)
add 925f7cc8749 Optimize table cache leader implement 2 (#14278)
add 3e8a201b319 [Vulnerability-check] Add weekly vulnerability-check #14288
add d3483237f75 Add avg file size in DefaultCompactionTaskComparatorImpl
(#14270)
add a7fbca63206 [Py-client] Support insert_records with None values
(#14272)
add 7e2329d461e Pipe: fix the issues of excessive stale PipeEventCommitter
logs and missing PipeDataNodeRemainingEventAndTimeMetrics (#14284)
add 76aec991ae1 Some configuration items may be commented out when merging
old version configuration files (#14248)
add 416eb39f868 Region Migration: Fix migration failed when there are
unknown nodes #14293
add 079fc8fd085 Subscription: basic support for table model from SQL to
IConfigTask & Pipe: fix too many warn logs from findAllStuckPipes() (#14287)
add 2b4ab69dff6 Add AccessControl support for query and database related
add a409dabf9c8 IoTConsensusV2: Fix up iotv2 wal check (#14280)
add 01f0a8fa30c Procedure: Fix procedure framework data race (#14250)
add b3892dac3cc Add TrimProperties to trim properties auto (#14289)
add a1a972c8462 feat(client-cpp): add basic TableModel settings &
insertRelationalTablet interface (#14097)
add 07e146faee6 [region migration] Handle InterruptedException during
waitTaskFinish() more properly #14305
add cfc5ef319e2 [Vulnerability-check] Adjust schedule time #14304
add 790bc26d4fc IoTV2: Improve create consensus log based on product
scenario #14306
add 54a6d818c57 Region Migration: Set default it to IoTV2 (#14294)
add 8f067a533ec update pom and add date IT
No new revisions were added by this update.
Summary of changes:
.github/workflows/vulnerability-check.yml | 49 +
.../src/AlignedTimeseriesSessionExample.cpp | 30 +-
example/client-cpp-example/src/SessionExample.cpp | 20 +-
.../src/TableModelSessionExample.cpp | 212 ++++
.../java/org/apache/iotdb/CountPointProcessor.java | 3 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 59 +-
.../org/apache/iotdb/DataMigrationExample.java | 26 +-
.../iotdb/HybridTimeseriesSessionExample.java | 10 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 16 +-
.../main/java/org/apache/iotdb/SessionExample.java | 62 +-
.../org/apache/iotdb/TableModelSessionExample.java | 28 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 30 +-
.../main/java/org/apache/iotdb/TabletExample.java | 3 +-
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 6 +-
.../db/query/udf/example/relational/AllSum.java | 5 +-
.../query/udf/example/relational/ContainNull.java | 5 +-
.../{ContainNull.java => DatePlusOne.java} | 30 +-
.../trigger/example/TriggerFireTimesCounter.java | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../it/env/remote/config/RemoteCommonConfig.java | 2 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 28 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
...onMigrateDataNodeCrashITFrameworkForIoTV1.java} | 17 +-
...onMigrateDataNodeCrashITFrameworkForIoTV2.java} | 3 +-
.../IoTDBRegionMigrateReliabilityITFramework.java | 3 +-
.../{ => commit}/IoTDBRegionMigrateNormalIT.java | 2 +-
.../{ => commit}/IoTDBRegionMigrateOtherIT.java | 2 +-
...inatorCrashWhenRemoveRemotePeerForIoTV1IT.java} | 15 +-
...IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java} | 18 +-
...riginalCrashWhenDeleteLocalPeerForIoTV1IT.java} | 8 +-
...iginalCrashWhenRemoveRemotePeerForIoTV1IT.java} | 8 +-
...inatorCrashWhenRemoveRemotePeerForIoTV2IT.java} | 15 +-
...IoTDBRegionMigrateDataNodeCrashForIoTV2IT.java} | 17 +-
...riginalCrashWhenDeleteLocalPeerForIoTV2IT.java} | 8 +-
...iginalCrashWhenRemoveRemotePeerForIoTV2IT.java} | 8 +-
.../IoTDBRegionMigrateClusterCrashIoTV1IT.java} | 18 +-
.../IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java} | 19 +-
.../IoTDBRegionMigrateClusterCrashIoTV2IT.java} | 5 +-
.../IoTDBRegionMigrateConfigNodeCrashIoTV2IT.java} | 5 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 24 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 8 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 23 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 49 +
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 4 +-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 5 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 55 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 4 +-
.../IoTDBPipeConnectorCompressionIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 6 +-
.../pipe/it/autocreate/IoTDBPipeNullValueIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 12 +-
.../pipe/it/autocreate/IoTDBPipeWithLoadIT.java | 4 +-
.../pipe/it/manual/AbstractPipeDualManualIT.java | 4 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 4 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 4 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 4 +-
.../pipe/it/manual/IoTDBPipeReqAutoSliceIT.java | 22 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 39 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../tablemodel/AbstractPipeTableModelTestIT.java | 4 +-
.../iotdb/pipe/it/tablemodel/IoTDBPipeAlterIT.java | 2 +
.../it/tablemodel/IoTDBPipeAutoConflictIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 4 +-
.../IoTDBPipeConnectorCompressionIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeExtractorIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java | 6 +-
.../pipe/it/tablemodel/IoTDBPipeProtocolIT.java | 12 +-
.../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 4 +-
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 32 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 80 +-
.../it/db/it/IoTDBDisableDeletionTableIT.java | 120 +++
.../relational/it/db/it/IoTDBInsertTableIT.java | 178 ++--
.../it/db/it/udf/scalar/IoTDBScalarFunctionIT.java | 41 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 48 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 23 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 122 ++-
.../pool/IoTDBInsertTableSessionPoolIT.java | 69 +-
.../session/it/IoTDBSessionAlignedInsertIT.java | 10 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 24 +-
.../it/IoTDBSessionDisableMemControlIT.java | 12 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 181 ++--
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 126 +--
.../session/it/IoTDBSessionSyntaxConventionIT.java | 4 +-
.../org/apache/iotdb/session/it/SessionIT.java | 21 +-
.../it/dual/AbstractSubscriptionDualIT.java | 4 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 2 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 6 +-
.../it/triple/IoTDBSubscriptionSharingIT.java | 6 +-
.../IoTDBDefaultPullConsumerDataSetIT.java | 2 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 2 +-
.../IoTDBRootDatasetPushConsumerIT.java | 2 +-
.../IoTDBRootPullConsumeTsfileIT.java | 2 +-
...merPullConsumerWith1TopicShareProcessMixIT.java | 2 +-
.../param/IoTDBTestParamPullConsumerIT.java | 2 +-
.../param/IoTDBTestParamPushConsumerIT.java | 2 +-
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 4 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 4 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 2 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 4 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 5 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBDBPatternPullConsumerDataSetIT.java | 2 +-
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 2 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 2 +-
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 2 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +-
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 2 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBTSPatternPullConsumerDataSetIT.java | 2 +-
.../time/IoTDBAllPullConsumerDataSetIT.java | 2 +-
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 2 +-
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 2 +-
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 2 +-
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 2 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 2 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 2 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 2 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 6 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 2 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 2 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 2 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +-
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 2 +-
.../regression/topic/IoTDBTestTopicNameIT.java | 2 +-
.../regression/user/IoTDBOtherUserConsumerIT.java | 2 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 12 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 16 +-
.../iotdb/udf/api/relational/ScalarFunction.java | 9 +-
.../src/assembly/resources/tools/export-data.bat | 6 +-
.../src/assembly/resources/tools/export-data.sh | 6 +-
.../src/assembly/resources/tools/import-data.bat | 6 +-
.../src/assembly/resources/tools/import-data.sh | 6 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 1106 +++++++++++++++++++-
.../apache/iotdb/tool/data/AsyncImportData.java | 160 +++
.../org/apache/iotdb/tool/data/ExportData.java | 397 +++++--
.../org/apache/iotdb/tool/data/ImportData.java | 1091 +++++++------------
.../apache/iotdb/tool/data/ImportDataScanTool.java | 63 ++
.../iotdb/tool/tsfile/AbstractTsFileTool.java | 3 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 124 ++-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 68 +-
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 10 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 11 +-
iotdb-client/client-cpp/pom.xml | 16 +
.../client-cpp/src/main/AbstractSessionBuilder.h | 25 +-
iotdb-client/client-cpp/src/main/Session.cpp | 110 +-
iotdb-client/client-cpp/src/main/Session.h | 173 ++-
iotdb-client/client-cpp/src/main/TableSession.cpp | 44 +
.../client-cpp/src/main/TableSession.h | 43 +-
.../client-cpp/src/main/TableSessionBuilder.h | 76 ++
iotdb-client/client-cpp/src/test/CMakeLists.txt | 9 +
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 2 +-
.../src/test/cpp/sessionRelationalIT.cpp | 117 +++
.../client-cpp/src/test/main_Relational.cpp | 42 +-
iotdb-client/client-py/iotdb/Session.py | 158 ++-
iotdb-client/client-py/iotdb/SessionPool.py | 20 +-
iotdb-client/client-py/iotdb/table_session.py | 147 +++
iotdb-client/client-py/iotdb/table_session_pool.py | 116 ++
...le.py => session_aligned_timeseries_example.py} | 0
.../{SessionExample.py => session_example.py} | 0
...ssionPoolExample.py => session_pool_example.py} | 0
...onExample.py => table_model_session_example.py} | 48 +-
...mple.py => table_model_session_pool_example.py} | 45 +-
.../tests => tests/integration/dbapi}/__init__.py | 0
.../integration/dbapi}/test_connection.py | 2 +-
.../integration/dbapi}/test_cursor.py | 2 +-
.../integration/iotdb_container.py} | 0
.../integration/sqlalchemy}/__init__.py | 0
.../integration/sqlalchemy}/test_dialect.py | 2 +-
.../tests/integration/test_aligned_timeseries.py | 2 +-
.../client-py/tests/integration/test_dataframe.py | 2 +-
.../tests/integration/test_delete_data.py | 2 +-
.../tests/integration/test_new_data_types.py | 2 +-
.../client-py/tests/integration/test_one_device.py | 2 +-
.../tests/integration/test_relational_session.py | 37 +-
.../client-py/tests/integration/test_session.py | 102 +-
.../tests/integration/test_session_pool.py | 2 +-
.../tests/integration/test_tablemodel_insert.py | 37 +-
.../client-py/tests/integration/test_tablet.py | 2 +-
.../client-py/tests/integration/test_todf.py | 2 +-
.../tests/integration/test_treemodel_insert.py | 3 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 80 +-
.../rpc/subscription/config/TopicConstant.java | 8 +
.../java/org/apache/iotdb/session/Session.java | 46 +-
.../apache/iotdb/session/SessionConnection.java | 374 ++-----
.../session/subscription/SubscriptionSession.java | 26 +-
.../payload/SubscriptionSessionDataSet.java | 6 +-
.../apache/iotdb/session/util/CheckedSupplier.java | 16 +-
.../apache/iotdb/session/util/SessionUtils.java | 42 +-
.../iotdb/session/SessionCacheLeaderTest.java | 190 ++--
.../java/org/apache/iotdb/session/SessionTest.java | 96 +-
.../java/org/apache/iotdb/session/TabletTest.java | 2 +-
.../session/pool/SessionPoolExceptionTest.java | 24 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 72 +-
.../iotdb/session/util/SessionUtilsTest.java | 114 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
iotdb-core/confignode/pom.xml | 6 +
.../confignode/conf/ConfigNodeDescriptor.java | 18 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../manager/consensus/ConsensusManager.java | 6 +-
.../load/cache/region/RegionGroupCache.java | 13 +-
.../manager/node/ClusterNodeStartUtils.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../manager/partition/RegionGroupStatus.java | 14 +-
.../confignode/procedure/ProcedureExecutor.java | 111 +-
.../procedure/env/RegionMaintainHandler.java | 27 +-
.../procedure/impl/node/AbstractNodeProcedure.java | 5 +-
.../impl/node/RemoveDataNodesProcedure.java | 19 +-
.../impl/region/AddRegionPeerProcedure.java | 5 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
.../confignode/conf/ConfigNodePropertiesTest.java | 50 +
.../confignode/manager/load/LoadManagerTest.java | 12 +-
.../manager/load/cache/RegionGroupCacheTest.java | 2 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 6 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 17 +-
.../service/PipeConsensusRPCServiceProcessor.java | 12 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 72 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 11 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 49 +-
.../schemaregion/SchemaExecutionVisitor.java | 36 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 23 +-
.../batch/PipeTabletEventTsFileBatch.java | 8 +-
.../request/PipeTransferTabletRawReq.java | 4 +-
.../request/PipeTransferTabletRawReqV2.java | 4 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 4 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 8 +-
.../pipe/connector/util/PipeTabletEventSorter.java | 16 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 8 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 14 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 25 +-
.../TabletInsertionEventTablePatternParser.java | 8 +-
.../TabletInsertionEventTreePatternParser.java | 2 +-
...ileInsertionEventQueryParserTabletIterator.java | 6 +-
.../scan/TsFileInsertionEventScanParser.java | 6 +-
...ileInsertionEventTableParserTabletIterator.java | 24 +-
.../dataregion/IoTDBDataRegionExtractor.java | 2 +
.../PipeRealtimeDataRegionHybridExtractor.java | 4 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 14 +
.../twostage/plugin/TwoStageCountProcessor.java | 1 -
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
...peStatementDataTypeConvertExecutionVisitor.java | 32 +-
.../visitor/PipeStatementTSStatusVisitor.java | 3 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 4 +
.../pipe/resource/tsfile/PipeTsFileResource.java | 4 +
.../resource/tsfile/PipeTsFileResourceManager.java | 19 +
.../common/schematree/ClusterSchemaTree.java | 4 +-
.../schematree/visitor/SchemaTreeVisitor.java | 2 +-
.../execution/MemoryEstimationHelper.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 30 +
.../execution/fragment/QueryContext.java | 15 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 15 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 12 +
.../db/queryengine/plan/analyze/TemplatedInfo.java | 2 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 12 +-
.../execution/config/TableConfigTaskVisitor.java | 103 +-
.../execution/config/TreeConfigTaskVisitor.java | 47 +-
.../config/executor/ClusterConfigTaskExecutor.java | 10 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../config/metadata/relational/ShowDBTask.java | 28 +-
.../config/sys/subscription/CreateTopicTask.java | 12 +-
.../config/sys/subscription/DropTopicTask.java | 11 +-
...riptionTask.java => ShowSubscriptionsTask.java} | 17 +-
.../config/sys/subscription/ShowTopicsTask.java | 12 +-
.../plan/parser/StatementGenerator.java | 6 +-
.../plan/planner/LogicalPlanBuilder.java | 5 +-
.../plan/planner/plan/node/write/InsertNode.java | 6 +-
.../planner/plan/node/write/InsertRowNode.java | 2 +-
.../planner/plan/node/write/InsertTabletNode.java | 2 +-
.../plan/node/write/RelationalDeleteDataNode.java | 8 +-
.../plan/relational/analyzer/Analyzer.java | 11 -
.../relational/analyzer/StatementAnalyzer.java | 60 +-
.../plan/relational/metadata/TableSchema.java | 12 +-
.../metadata/fetcher/cache/SchemaCacheEntry.java | 4 +-
.../cache/TreeDeviceSchemaCacheManager.java | 6 +-
.../plan/relational/planner/TableModelPlanner.java | 9 +-
.../plan/relational/security/AccessControl.java | 113 +-
.../relational/security/AccessControlImpl.java | 91 ++
.../relational/security/AllowAllAccessControl.java | 64 +-
.../relational/security/ITableAuthChecker.java | 75 ++
...AccessControl.java => TableModelPrivilege.java} | 15 +-
.../plan/relational/sql/ast/AstVisitor.java | 16 +
.../plan/relational/sql/ast/CreateTopic.java | 87 ++
.../plan/relational/sql/ast/DeleteDevice.java | 2 +
.../plan/relational/sql/ast/DropColumn.java | 15 +-
.../plan/relational/sql/ast/DropTopic.java | 75 ++
.../plan/relational/sql/ast/ShowSubscriptions.java | 66 ++
.../plan/relational/sql/ast/ShowTopics.java | 66 ++
.../ast/SubscriptionStatement.java} | 18 +-
.../plan/relational/sql/parser/AstBuilder.java | 57 +-
.../plan/relational/sql/util/SqlFormatter.java | 70 ++
.../queryengine/plan/statement/StatementType.java | 2 +-
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../metadata/subscription/DropTopicStatement.java | 1 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 52 +-
.../rescon/DataNodeSchemaQuotaManager.java | 4 +-
.../rescon/MemSchemaRegionStatistics.java | 5 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 25 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 7 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 27 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 3 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 9 +-
.../schemaregion/utils/MNodeUtils.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 1 +
.../iotdb/db/schemaengine/template/Template.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../impl/ReadPointCompactionPerformer.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 4 +
.../execute/utils/CompactionTableSchema.java | 28 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 4 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 2 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 2 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 8 +-
...FollowingBatchCompactionAlignedChunkWriter.java | 2 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 2 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 2 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 2 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 4 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 2 +-
.../compaction/io/CompactionTsFileWriter.java | 6 +-
.../DefaultCompactionTaskComparatorImpl.java | 12 +-
.../dataregion/memtable/AbstractMemTable.java | 10 +-
.../memtable/AlignedReadOnlyMemChunk.java | 2 +-
.../memtable/AlignedWritableMemChunk.java | 12 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 2 +-
.../modification/TableDeletionEntry.java | 4 +
.../dataregion/tsfile/TsFileManager.java | 11 +-
.../dataregion/utils/TsFileResourceUtils.java | 14 +-
.../dataregion/wal/utils/WALWriteUtils.java | 4 +-
.../splitter/BatchedAlignedValueChunkData.java | 2 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 4 +-
.../db/trigger/executor/TriggerFireVisitor.java | 5 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 22 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 4 +-
.../iotdb/db/{utils => conf}/PropertiesTest.java | 35 +-
.../mtree/schemafile/WrappedSegmentTest.java | 4 +-
.../connector/PipeDataNodeThriftRequestTest.java | 37 +-
.../pipe/connector/PipeTabletEventSorterTest.java | 60 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 12 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 1 -
.../resource/PipeTsFileResourceManagerTest.java | 31 +-
.../common/schematree/ClusterSchemaTreeTest.java | 4 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 2 +-
.../operator/AlignedSeriesScanOperatorTest.java | 10 +-
.../execution/operator/AlignedSeriesTestUtil.java | 12 +-
.../schema/SchemaFetchScanOperatorTest.java | 2 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 71 ++
.../plan/optimization/OptimizationTestUtil.java | 2 +
.../plan/optimization/TestPlanBuilder.java | 45 +
.../plan/parser/StatementGeneratorTest.java | 6 +-
.../logical/RegionScanLogicalPlannerTest.java | 75 +-
.../node/write/RelationalDeleteDataNodeTest.java | 24 +-
.../plan/relational/analyzer/AnalyzerTest.java | 5 +-
.../plan/relational/planner/PlanTester.java | 6 +-
.../storageengine/buffer/BloomFilterCacheTest.java | 12 +-
.../db/storageengine/buffer/ChunkCacheTest.java | 8 +-
.../storageengine/dataregion/DataRegionTest.java | 60 +-
.../dataregion/LastFlushTimeMapTest.java | 20 +-
.../compaction/AbstractCompactionTest.java | 2 +-
.../compaction/CompactionDataTypeNotMatchTest.java | 24 +-
.../compaction/CompactionTaskComparatorTest.java | 25 +-
.../compaction/CompactionValidationTest.java | 12 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 32 +
.../dataregion/compaction/cross/MergeTest.java | 8 +-
.../compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 38 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 8 +-
.../inner/FastCompactionPerformerAlignedTest.java | 16 +-
.../FastCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 8 +-
.../compaction/inner/InnerCompactionTest.java | 8 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 12 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 16 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../SizeTieredCompactionRecoverTest.java | 44 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 26 +-
.../settle/SettleRequestHandlerTest.java | 2 +-
.../CompactionTableModelTestFileWriter.java | 6 +-
.../CompactionTableSchemaCollectorTest.java | 54 +-
.../compaction/utils/CompactionCheckerUtils.java | 2 +-
.../dataregion/memtable/TsFileProcessorTest.java | 48 +-
.../read/reader/series/SeriesReaderTestUtil.java | 10 +-
.../wal/recover/WALRecoverManagerTest.java | 20 +-
.../file/SealedTsFileRecoverPerformerTest.java | 36 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 20 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 20 +-
.../rescon/memory/ResourceManagerTest.java | 8 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 6 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 12 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 20 +-
.../iotdb/db/utils/ConfigurationFileUtilsTest.java | 80 ++
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 2 +-
.../metrics/config/MetricConfigDescriptor.java | 6 +-
.../iotdb/commons/client/ClientPoolFactory.java | 22 +-
.../client/request/TestConnectionUtils.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 21 +-
.../iotdb/commons/conf/CommonDescriptor.java | 17 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 2 +-
.../apache/iotdb/commons/conf/TrimProperties.java | 46 +-
.../exception/auth/AccessDeniedException.java} | 14 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 2 +-
.../iotdb/commons/path/NonAlignedFullPath.java | 4 +-
.../task/progress/PipeEventCommitManager.java | 26 +-
.../pipe/config/constant/SystemConstant.java | 2 +
.../schema/table/column/TsTableColumnCategory.java | 12 +-
.../commons/schema/view/LogicalViewSchema.java | 22 +-
.../commons/subscription/meta/topic/TopicMeta.java | 19 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 38 +-
.../src/main/thrift/pipeconsensus.thrift | 1 +
pom.xml | 2 +-
468 files changed, 8288 insertions(+), 3599 deletions(-)
create mode 100644 .github/workflows/vulnerability-check.yml
create mode 100644 example/client-cpp-example/src/TableModelSessionExample.cpp
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{ContainNull.java
=> DatePlusOne.java} (61%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/{IoTDBRegionMigrateDataNodeCrashITFramework.java
=> IoTDBRegionMigrateDataNodeCrashITFrameworkForIoTV1.java} (73%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/{IoTDBRegionMigrateDataNodeCrashITFramework.java
=> IoTDBRegionMigrateDataNodeCrashITFrameworkForIoTV2.java} (94%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{
=> commit}/IoTDBRegionMigrateNormalIT.java (95%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{
=> commit}/IoTDBRegionMigrateOtherIT.java (96%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerIT.java
=>
daily/datanodecrash/iotv1/IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV1IT.java}
(84%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateDataNodeCrashIT.java
=> daily/datanodecrash/iotv1/IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java}
(86%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerIT.java
=>
daily/datanodecrash/iotv1/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV1IT.java}
(84%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerIT.java
=>
daily/datanodecrash/iotv1/IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV1IT.java}
(88%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerIT.java
=>
daily/datanodecrash/iotv2/IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2IT.java}
(84%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateDataNodeCrashIT.java
=> daily/datanodecrash/iotv2/IoTDBRegionMigrateDataNodeCrashForIoTV2IT.java}
(87%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerIT.java
=>
daily/datanodecrash/iotv2/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2IT.java}
(84%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{datanodecrash/IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerIT.java
=>
daily/datanodecrash/iotv2/IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2IT.java}
(88%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{IoTDBRegionMigrateClusterCrashIT.java
=> daily/iotv1/IoTDBRegionMigrateClusterCrashIoTV1IT.java} (81%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{IoTDBRegionMigrateConfigNodeCrashIT.java
=> daily/iotv1/IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java} (88%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{IoTDBRegionMigrateClusterCrashIT.java
=> daily/iotv2/IoTDBRegionMigrateClusterCrashIoTV2IT.java} (92%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{IoTDBRegionMigrateConfigNodeCrashIT.java
=> daily/iotv2/IoTDBRegionMigrateConfigNodeCrashIoTV2IT.java} (95%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDisableDeletionTableIT.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AsyncImportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataScanTool.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionMigrateDataNodeCrashITFramework.java
=> iotdb-client/client-cpp/src/main/AbstractSessionBuilder.h (65%)
create mode 100644 iotdb-client/client-cpp/src/main/TableSession.cpp
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/AbstractPipeSingleIT.java
=> iotdb-client/client-cpp/src/main/TableSession.h (52%)
create mode 100644 iotdb-client/client-cpp/src/main/TableSessionBuilder.h
create mode 100644 iotdb-client/client-cpp/src/test/cpp/sessionRelationalIT.cpp
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/AbstractPipeSingleIT.java
=> iotdb-client/client-cpp/src/test/main_Relational.cpp (50%)
create mode 100644 iotdb-client/client-py/iotdb/table_session.py
create mode 100644 iotdb-client/client-py/iotdb/table_session_pool.py
rename iotdb-client/client-py/{SessionAlignedTimeseriesExample.py =>
session_aligned_timeseries_example.py} (100%)
rename iotdb-client/client-py/{SessionExample.py => session_example.py} (100%)
rename iotdb-client/client-py/{SessionPoolExample.py =>
session_pool_example.py} (100%)
rename iotdb-client/client-py/{TableModelSessionExample.py =>
table_model_session_example.py} (83%)
rename iotdb-client/client-py/{TableModelSessionPoolExample.py =>
table_model_session_pool_example.py} (85%)
rename iotdb-client/client-py/{iotdb/dbapi/tests =>
tests/integration/dbapi}/__init__.py (100%)
rename iotdb-client/client-py/{iotdb/dbapi/tests =>
tests/integration/dbapi}/test_connection.py (96%)
rename iotdb-client/client-py/{iotdb/dbapi/tests =>
tests/integration/dbapi}/test_cursor.py (98%)
rename iotdb-client/client-py/{iotdb/IoTDBContainer.py =>
tests/integration/iotdb_container.py} (100%)
rename iotdb-client/client-py/{iotdb/sqlalchemy/tests =>
tests/integration/sqlalchemy}/__init__.py (100%)
rename iotdb-client/client-py/{iotdb/sqlalchemy/tests =>
tests/integration/sqlalchemy}/test_dialect.py (98%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/AccessControl.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/CheckedSupplier.java
(61%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodePropertiesTest.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/subscription/{ShowSubscriptionTask.java
=> ShowSubscriptionsTask.java} (80%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/AccessControlImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/ITableAuthChecker.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/{AccessControl.java
=> TableModelPrivilege.java} (83%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreateTopic.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropTopic.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowSubscriptions.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowTopics.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/{security/AllowAllAccessControl.java
=> sql/ast/SubscriptionStatement.java} (69%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{utils =>
conf}/PropertiesTest.java (77%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/ConfigurationFileUtilsTest.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/AbstractPipeSingleIT.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/TrimProperties.java
(50%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/AccessControl.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/auth/AccessDeniedException.java}
(66%)
