This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch time-partition-boundary-overflow-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from eda0433e1f9 Merge branch 'master' of https://github.com/apache/iotdb
into time-partition-boundary-overflow-fix
add e123ada23ec Respect pre-set env vars and add cgroup memory detection
in env scripts (#17765)
add d02e6af593a A lease-based self-fencing framework to enable high
availability for table metadata operations
add 506f94519fb Extend region migration speed limit to transfers and
deletion (#18118)
add afdcf327e3e Update programming languages and release notes for version
2.0.10 (#18164)
add 449946d5268 Fix pipe event accounting and aligned tablet failure
reporting (#18150)
add 33a38b6194d Pipe: manage ConfigNode receiver temporary memory (#18144)
add c716365a30f Fix subscription consumer lifecycle state ordering (#18151)
add 5aad9323c71 Reduce pipe type conversion log frequency (#18161)
add 343edab9c00 Fix IT log directory test class names (#18131)
add 9112791a88c Fix: remove some procedure that should not be included in
lease frame (#18167)
add ec81de1f9f2 Reduce pipe load success log noise (#18106)
add 7ccdaa503e2 Pipe: use session context in legacy receiver loaders
(#18111)
add 4482e65468a Fix pipe drop stuck on blocking sink reconnect (#18145)
add e8061edf668 Optimize load logic (#18153)
add 350c6c7bcd2 Optimize pipe TsFile cleanup on drop (#18163)
add 86741a8cfeb Fix compaction test metadata lease cleanup (#18172)
add da07a8ef8a1 Subscription: support table-model column-filter for topics
(#17936)
add 9f069d5c7c5 Fix that ProgressWALIterator may read incorrect
searchIndex (#18143)
add 8235112d353 Fix no-tag table attribute deletion (#18176)
add 8735702a775 Reduce repeated failure logs (#18175)
add b05f4cadb76 Avoid readLock when serializing TimeIndex. (#18189)
add ce74949268e Fix tag index misalignment in read_tsfile when projection
pruning removes tag columns (#18191)
add 5ceb047fe83 Fix DataNode restart readiness race in IoTDBConnectionsIT
(#18192)
add 7ffb1364b84 Add mutual SSL support for pipe sinks (#18080)
add eaef430d2b9 Enforce REST query row limit as hard cap (#18149)
add 0d3304a106a Fix RPC buffer memory control activation (#18194)
add ededa9a57ba Pipe IT: disable pipe memory control in overridden setups
(#18198)
add e75d1466251 Fix retry bug in tree model query which ignore the time
filter (#18179)
add 5bb15d980f4 Pipe: optimize InsertRows schema aggregation (#18195)
add f1875ed5d06 Fix external TsFile grouping optimization (#18206)
add d8506920bf8 Improve error message when auto-creating timeseries with
null value (#18209)
add 32bff9b615a Fix procedures stuck after submission-time deserialization
failure (#18212)
add 2c77de3670c Prevent aligned LAST query from hanging with time filter
(#18213)
add 8b60437ee42 Fix write retries, Pipe resource cleanup, subscription
progress, and snapshot recovery (#18180)
add fe1777bfa6d Optimize pipe tablet memory accounting (#18211)
add dfbe8db321d Fix MQTT measurement validation (#18215)
add 0ef17ba7677 Support IPv6 endpoint URLs (#18162)
add 66e4b98ebd8 Optimize TopK query of TableModel by RuntimeFilter (#18204)
add ce9838da272 Fix duplicate TsFile metric updates (#18219)
add 9ae66742b9e Only scan tables of tree model while regenerating data
partition (#18221)
add 386d537d497 Merge branch 'master' of https://github.com/apache/iotdb
into time-partition-boundary-overflow-fix
No new revisions were added by this update.
Summary of changes:
RELEASE_NOTES.md | 38 +
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 5 +-
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 1 +
.../src/main/openapi3/iotdb_rest_v1.yaml | 1 +
.../src/main/openapi3/iotdb_rest_v2.yaml | 1 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 3 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 3 +
.../rest/protocol/handler/QueryRowLimitUtils.java | 71 +
.../table/v1/handler/QueryDataSetHandler.java | 44 +-
.../protocol/table/v1/impl/RestApiServiceImpl.java | 9 +-
.../protocol/v1/handler/QueryDataSetHandler.java | 114 +-
.../protocol/v1/impl/GrafanaApiServiceImpl.java | 19 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 8 +-
.../rest/protocol/v2/handler/FastLastHandler.java | 65 +-
.../protocol/v2/handler/QueryDataSetHandler.java | 114 +-
.../protocol/v2/impl/GrafanaApiServiceImpl.java | 19 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 48 +-
.../protocol/handler/QueryRowLimitUtilsTest.java | 59 +
.../v1/handler/QueryDataSetHandlerTest.java | 222 +++
.../protocol/v2/handler/FastLastHandlerTest.java | 119 ++
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 8 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 1 +
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 44 +-
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 9 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 6 +-
.../it/env/remote/config/RemoteCommonConfig.java | 5 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 23 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../org/apache/iotdb/db/it/IoTDBIPv6ClusterIT.java | 124 ++
.../iotdb/db/it/IoTDBIPv6ExternalServiceIT.java | 220 +++
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 11 +
.../apache/iotdb/db/it/IoTDBLoadTsFileAuthIT.java | 285 ++++
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 24 +
... => IoTDBAlignedLastQueryWithTimeFilterIT.java} | 44 +-
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 19 +-
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 41 +
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 2 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 8 +
.../framework/IoTDBTestRunnerWithParameters.java | 15 +-
.../org/apache/iotdb/it/utils/IPv6TestUtils.java | 60 +
.../manual/enhanced/IoTDBPipeClusterIT.java | 2 +-
.../dual/treemodel/auto/basic/IoTDBPipeIPv6IT.java | 166 +++
.../treemodel/auto/basic/IoTDBPipeMutualSSLIT.java | 176 +++
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 16 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 2 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 6 +-
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 109 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 18 +
.../recent/IoTDBReadTsFileTableFunctionIT.java | 50 +
.../recent/IoTDBTopKRuntimeFilterScanPathIT.java | 353 +++++
.../relational/it/schema/IoTDBTableDDLHAIT.java | 289 ++++
.../iotdb/session/it/IoTDBConnectionsIT.java | 30 +-
.../apache/iotdb/session/it/IoTDBIPv6ClientIT.java | 142 ++
.../ConsensusSubscriptionTableITSupport.java | 336 ++++-
...ConsensusSubscriptionColumnFilterClusterIT.java | 232 +++
.../IoTDBConsensusSubscriptionFilterTableIT.java | 188 ++-
.../IoTDBSubscriptionColumnFilterIT.java | 1513 ++++++++++++++++++++
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 76 +
.../api/customizer/parameter/PipeParameters.java | 1 +
.../customizer/parameter/PipeParametersTest.java | 12 +
iotdb-client/client-cpp/src/rpc/NodesSupplier.cpp | 5 +-
iotdb-client/client-cpp/src/rpc/RpcCommon.cpp | 23 +
iotdb-client/client-cpp/src/rpc/RpcCommon.h | 2 +
iotdb-client/client-cpp/src/session/Session.cpp | 4 +-
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 15 +
iotdb-client/client-cpp/test/main.cpp | 5 +-
iotdb-client/client-py/iotdb/Session.py | 85 +-
.../client-py/tests/unit/test_session_node_url.py | 85 ++
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 77 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 46 +
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 24 +-
.../iotdb/rpc/AutoResizingBufferMemoryManager.java | 25 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../main/java/org/apache/iotdb/rpc/UrlUtils.java | 85 +-
.../apache/iotdb/rpc/AutoResizingBufferTest.java | 37 +
.../java/org/apache/iotdb/rpc/UrlUtilsTest.java | 80 ++
.../apache/iotdb/session/i18n/SessionMessages.java | 2 +
.../apache/iotdb/session/i18n/SessionMessages.java | 2 +
.../org/apache/iotdb/session/NodesSupplier.java | 5 +-
.../java/org/apache/iotdb/session/Session.java | 5 +-
.../apache/iotdb/session/SessionConnection.java | 11 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 7 +-
.../apache/iotdb/session/util/SessionUtils.java | 8 +-
.../src/test/resources/iotdb-common.properties | 3 +-
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 31 +
.../rpc/subscription/config/TopicConstant.java | 4 +-
.../payload/poll/SubscriptionPollResponse.java | 111 +-
.../base/AbstractSubscriptionConsumer.java | 26 +-
.../base/AbstractSubscriptionProviders.java | 6 +
.../base/AbstractSubscriptionPullConsumer.java | 10 +-
.../base/AbstractSubscriptionPushConsumer.java | 10 +-
.../subscription/payload/SubscriptionMessage.java | 39 +-
.../payload/SubscriptionRecordHandler.java | 161 ++-
.../rpc/subscription/config/TopicConfigTest.java | 59 +
.../payload/poll/SubscriptionPollResponseTest.java | 138 ++
.../base/SubscriptionConsumerLifecycleTest.java | 267 ++++
.../payload/SubscriptionRecordHandlerTest.java | 176 +++
iotdb-core/ainode/iotdb/ainode/core/config.py | 17 +-
.../ainode/iotdb/ainode/core/ingress/iotdb.py | 11 +-
.../ainode/resources/conf/iotdb-ainode.properties | 3 +-
iotdb-core/ainode/tests/test_config.py | 71 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 2 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 2 +
.../calc/execution/filter/TopKRuntimeFilter.java | 67 +
.../operator/process/TableTopKOperator.java | 40 +-
.../execution/operator/process/TopKOperator.java | 36 +
.../calc/plan/planner/TableOperatorGenerator.java | 25 +
.../execution/filter/TopKRuntimeFilterTest.java | 73 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 1 +
.../iotdb/confignode/i18n/ManagerMessages.java | 17 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 339 +++--
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 416 +++---
.../iotdb/confignode/i18n/ManagerMessages.java | 17 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 921 +++++++-----
.../CnToCnInternalServiceAsyncRequestManager.java | 4 +-
.../client/async/CnToDnAsyncRequestType.java | 3 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 13 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 3 +-
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 17 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../confignode/conf/ConfigNodeMemoryConfig.java | 4 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/read/table/FetchTablePlan.java | 10 +-
...lePlan.java => RollbackPreDeleteTablePlan.java} | 10 +-
.../statemachine/ConfigRegionStateMachine.java | 10 +
.../iotdb/confignode/manager/ClusterManager.java | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 141 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +-
.../iotdb/confignode/manager/ProcedureManager.java | 87 ++
.../externalservice/ExternalServiceInfo.java | 2 +-
.../manager/lease/ClusterCachePropagator.java | 159 ++
.../manager/lease/DataNodeContactTracker.java | 110 ++
.../manager/lease/MetadataBroadcastVerdict.java | 66 +
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../manager/partition/PartitionManager.java | 34 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 29 +-
.../agent/runtime/PipeConfigRegionListener.java | 19 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 47 +-
.../resource/PipeConfigNodeResourceManager.java | 17 +-
.../memory/PipeConfigNodeMemoryManager.java | 115 ++
.../client/IoTDBConfigNodeSyncClientManager.java | 4 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 4 +
.../manager/schema/ClusterSchemaManager.java | 65 +-
.../persistence/executor/ConfigPlanExecutor.java | 19 +-
.../confignode/persistence/pipe/PipeInfo.java | 5 -
.../confignode/persistence/quota/QuotaInfo.java | 1 +
.../persistence/schema/ClusterSchemaInfo.java | 25 +-
.../confignode/persistence/schema/ConfigMTree.java | 48 +-
.../persistence/schema/TemplatePreSetTable.java | 2 +
.../persistence/schema/TemplateTable.java | 12 +-
.../persistence/subscription/SubscriptionInfo.java | 106 +-
.../confignode/procedure/ProcedureExecutor.java | 28 +
.../procedure/env/ConfigNodeProcedureEnv.java | 97 +-
.../procedure/env/RemoveDataNodeHandler.java | 3 +
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 9 +-
.../impl/schema/AlterLogicalViewProcedure.java | 33 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 32 +-
.../impl/schema/DeactivateTemplateProcedure.java | 2 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 32 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 35 +-
.../procedure/impl/schema/SchemaUtils.java | 110 +-
.../impl/schema/SetTemplateProcedure.java | 2 +-
.../table/AbstractAlterOrDropTableProcedure.java | 36 +-
.../impl/schema/table/CreateTableProcedure.java | 36 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 51 +-
.../schema/table/DropTableColumnProcedure.java | 66 +-
.../impl/schema/table/DropTableProcedure.java | 90 +-
.../runtime/CommitProgressSyncProcedure.java | 47 +-
.../subscription/CreateSubscriptionProcedure.java | 28 +
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../procedure/state/schema/DropTableState.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 2 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../manager/ConfigManagerCommitProgressTest.java | 241 ++++
.../confignode/manager/ProcedureManagerTest.java | 38 +
.../manager/lease/ClusterCachePropagatorTest.java | 189 +++
.../manager/lease/DataNodeContactTrackerTest.java | 73 +
.../lease/MetadataBroadcastVerdictTest.java | 77 +
.../PipeConfigRegionListenerSnapshotTest.java | 59 +
.../pipe/sink/IoTDBConfigRegionSinkTest.java | 46 +
.../persistence/ExternalServiceInfoTest.java | 21 +
.../confignode/persistence/QuotaInfoTest.java | 14 +
.../schema/TemplatePreSetTableTest.java | 19 +-
.../persistence/schema/TemplateTableTest.java | 10 +-
.../subscription/SubscriptionInfoTest.java | 40 +
.../SubscriptionInfoTopicValidationTest.java | 86 +-
.../procedure/TestProcedureExecutor.java | 127 ++
.../runtime/CommitProgressSyncProcedureTest.java | 140 ++
.../CreateSubscriptionProcedureTest.java | 37 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 5 +-
.../iot/snapshot/IoTConsensusRateLimiter.java | 22 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 5 +-
.../consensus/ratis/RateLimitedGrpcFactory.java} | 29 +-
.../ratis/RateLimitedGrpcLogAppender.java | 76 +
.../consensus/ratis/RateLimitedGrpcRpcType.java} | 18 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +
.../apache/iotdb/consensus/ratis/utils/Utils.java | 9 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 5 +-
.../ratis/RateLimitedGrpcLogAppenderTest.java | 66 +
.../iotdb/consensus/ratis/utils/UtilsTest.java | 54 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 48 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 88 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 90 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 3 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 48 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 81 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 68 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 3 +
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 16 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 12 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 34 +-
.../exception/metadata/PathNotExistException.java | 13 +
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 10 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 22 +
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 198 ++-
.../common/tsfile/PipeTsFileInsertionEvent.java | 7 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 82 +-
.../protocol/legacy/loader/DeletionLoader.java | 25 +-
.../receiver/protocol/legacy/loader/ILoader.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 16 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 30 +-
.../statement/PipeConvertedInsertRowStatement.java | 30 +-
.../PipeConvertedInsertTabletStatement.java | 14 +-
...leStatementDataTypeConvertExecutionVisitor.java | 16 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 9 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 85 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 24 +-
.../pipe/resource/tsfile/PipeTsFileResource.java | 8 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 39 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 19 +-
.../client/IoTDBDataNodeSyncClientManager.java | 10 +-
.../evolvable/batch/PipeTabletEventBatch.java | 14 +-
.../batch/PipeTabletEventTsFileBatch.java | 79 +-
.../request/PipeTransferTabletBatchReqV2.java | 13 +-
.../request/PipeTransferTabletRawReqV2.java | 16 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 31 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 16 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 32 +-
.../handler/IoTConsensusV2DeleteEventHandler.java | 2 +-
.../IoTConsensusV2TabletBatchEventHandler.java | 2 +-
.../IoTConsensusV2TabletInsertionEventHandler.java | 2 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 2 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 123 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 3 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 2 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 89 +-
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../handler/PipeTransferTrackableHandler.java | 4 +-
.../async/handler/PipeTransferTsFileHandler.java | 33 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 4 +
.../thrift/sync/IoTDBDataRegionSyncSink.java | 29 +-
.../sink/protocol/writeback/WriteBackSink.java | 2 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 19 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 16 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 8 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 18 +-
.../realtime/epoch/TsFileEpochManager.java | 70 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 12 +-
.../DnToCnInternalServiceAsyncRequestManager.java | 4 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 5 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 11 +-
.../thrift/impl/DataNodeRegionManager.java | 8 +-
.../execution/fragment/DataNodeQueryContext.java | 21 +
.../execution/operator/source/SeriesScanUtil.java | 133 +-
.../relational/AbstractTableScanOperator.java | 23 +-
.../ExternalTsFileTableScanOperator.java | 13 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 106 +-
.../db/queryengine/plan/analyze/Analyzer.java | 16 +-
.../plan/analyze/ConcatPathRewriter.java | 23 +-
.../queryengine/plan/analyze/PredicateUtils.java | 177 ++-
.../plan/analyze/TemplatedAggregationAnalyze.java | 71 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 20 +-
.../plan/analyze/TreeAnalysisMutationJournal.java | 255 ++++
.../analyze/cache/partition/PartitionCache.java | 12 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 70 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 72 +-
.../queryengine/plan/execution/QueryExecution.java | 47 +-
.../execution/config/TableConfigTaskVisitor.java | 41 +
.../execution/config/TreeConfigTaskVisitor.java | 14 +
.../config/executor/ClusterConfigTaskExecutor.java | 7 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../execution/config/sys/TestConnectionTask.java | 3 +-
.../visitor/predicate/PredicateSimplifier.java | 83 +-
.../planner/DataNodeTableOperatorGenerator.java | 158 +-
.../db/queryengine/plan/planner/IPlanner.java | 6 +
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 7 +
.../plan/planner/plan/node/PlanVisitor.java | 2 +-
.../planner/plan/parameter/SeriesScanOptions.java | 19 +-
.../relational/analyzer/StatementAnalyzer.java | 21 +-
.../relational/metadata/TableMetadataImpl.java | 3 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 3 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 6 +-
.../cache/TreeDeviceSchemaCacheManager.java | 13 +-
.../distribute/TableDistributedPlanGenerator.java | 11 +-
.../distribute/TableDistributedPlanner.java | 5 +-
.../planner/node/DeviceTableScanNode.java | 49 +-
.../optimizations/LogicalOptimizeFactory.java | 1 +
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../optimizations/TopKRuntimeFilterOptimizer.java | 83 ++
.../sql/ast/AbstractQueryDeviceWithCache.java | 24 +
.../plan/relational/sql/ast/CountDevice.java | 9 +
.../plan/relational/sql/ast/InsertRows.java | 115 +-
.../plan/relational/sql/ast/ShowDevice.java | 11 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 75 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 27 +-
.../plan/statement/component/GroupByComponent.java | 5 +
.../plan/statement/component/OrderByComponent.java | 30 +
.../plan/statement/component/WhereCondition.java | 7 +
.../plan/statement/crud/InsertBaseStatement.java | 11 +-
.../plan/statement/crud/InsertRowStatement.java | 10 +-
.../schemaengine/lease/MetadataLeaseManager.java | 312 ++++
.../schemaregion/SchemaRegionLoader.java | 8 +-
.../schemaregion/SchemaRegionUtils.java | 14 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 4 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 367 +++--
.../iotdb/db/schemaengine/table/ITableCache.java | 24 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 1 +
.../db/service/metrics/DataNodeMetricsHelper.java | 3 +
.../iotdb/db/service/metrics/FileMetrics.java | 8 +-
.../metrics/MetadataLeaseMetrics.java} | 43 +-
.../db/service/metrics/file/TsFileMetrics.java | 19 +-
.../iotdb/db/storageengine/StorageEngine.java | 9 +-
.../db/storageengine/dataregion/DataRegion.java | 316 ++--
.../dataregion/HashLastFlushTimeMap.java | 1 +
.../execute/task/CrossSpaceCompactionTask.java | 4 +-
.../execute/task/InnerSpaceCompactionTask.java | 5 +-
.../task/InsertionCrossSpaceCompactionTask.java | 12 +-
.../execute/task/SettleCompactionTask.java | 3 +-
.../compaction/execute/utils/CompactionUtils.java | 17 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 11 +-
.../dataregion/memtable/TsFileProcessor.java | 120 +-
.../dataregion/read/QueryDataSource.java | 114 ++
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 20 +-
.../dataregion/wal/allocation/ElasticStrategy.java | 5 +-
.../wal/allocation/FirstCreateStrategy.java | 5 +-
.../load/active/ActiveLoadPathHelper.java | 50 +-
.../load/active/ActiveLoadTsFileLoader.java | 9 +
.../iotdb/db/storageengine/load/util/LoadUtil.java | 28 +-
.../agent/SubscriptionBrokerAgent.java | 155 +-
.../agent/SubscriptionConsumerAgent.java | 55 +-
.../subscription/agent/SubscriptionTopicAgent.java | 56 +-
.../broker/ConsensusSubscriptionBroker.java | 5 +-
.../broker/SubscriptionPrefetchingQueue.java | 15 +-
.../consensus/ConsensusLogToTabletConverter.java | 254 ++--
.../consensus/ConsensusPrefetchingQueue.java | 325 ++++-
.../ConsensusSubscriptionCommitManager.java | 524 ++++++-
.../ConsensusSubscriptionSetupHandler.java | 168 ++-
.../broker/consensus/ProgressWALIterator.java | 5 +-
.../columnfilter/BoundColumnFilter.java | 146 ++
.../columnfilter/ColumnFilterBinder.java | 169 +++
.../columnfilter/ColumnFilterEvaluator.java | 183 +++
.../columnfilter/ColumnFilterMatcher.java | 202 +++
.../columnfilter/ColumnFilterParser.java | 296 ++++
.../columnfilter/ColumnFilterValidator.java | 174 +++
.../columnfilter/TabletColumnPruner.java | 189 +++
.../columnfilter/TreeViewTabletProjector.java | 168 +++
.../db/subscription/event/SubscriptionEvent.java | 29 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 179 ++-
.../batch/SubscriptionPipeTsFileEventBatch.java | 57 +-
.../cache/CachedSubscriptionPollResponse.java | 24 +-
.../response/SubscriptionEventSingleResponse.java | 20 +
.../response/SubscriptionEventTabletResponse.java | 54 +-
.../response/SubscriptionEventTsFileResponse.java | 22 +-
.../db/auth/ClusterAuthorityFetcherLeaseTest.java | 103 ++
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 17 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 30 +
.../task/subtask/sink/PipeSinkSubtaskTest.java | 254 ++++
.../InsertNodeMemoryEstimatorPerformanceTest.java | 104 ++
.../memory/InsertNodeMemoryEstimatorTest.java | 130 ++
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 120 ++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 45 +
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 193 +++
.../batch/PipeTabletEventTsFileBatchTest.java | 64 +
...ipeTransferTabletBatchReqV2PerformanceTest.java | 133 ++
.../PipeTransferTsFileHandlerCleanupTest.java | 86 ++
.../sink/util/builder/PipeTsFileBuilderV2Test.java | 264 ++++
.../realtime/PipeRealtimeDataRegionSourceTest.java | 113 ++
.../epoch/TsFileEpochManagerPerformanceTest.java | 212 +++
.../realtime/epoch/TsFileEpochManagerTest.java | 105 ++
...alTsFileTableScanOperatorRuntimeFilterTest.java | 127 ++
.../db/queryengine/plan/analyze/AnalyzeTest.java | 238 +++
.../plan/analyze/PredicateUtilsTest.java | 172 +++
.../plan/analyze/TemplatedAnalyzeRetryTest.java | 127 ++
.../analyze/cache/PartitionCacheLeaseTest.java | 129 ++
.../plan/execution/QueryExecutionRetryTest.java | 218 +++
.../plan/planner/LogicalPlanBuilderTest.java | 113 ++
.../plan/relational/analyzer/AnalyzerTest.java | 117 ++
.../TreeDeviceSchemaCacheManagerLeaseTest.java | 119 ++
.../planner/assertions/PlanMatchPattern.java | 25 +
.../optimizations/ParallelizeGroupingTest.java | 111 ++
.../TopKRuntimeFilterDistributedPlanTest.java | 200 +++
.../TopKRuntimeFilterTreeViewPlanTest.java | 119 ++
.../plan/statement/QueryStatementTest.java | 26 +
.../lease/MetadataLeaseManagerTest.java | 114 ++
.../schemaengine/lease/MetadataLeaseTestUtils.java | 77 +
.../table/DataNodeTableCacheLeaseTest.java | 90 ++
.../schemaengine/table/DataNodeTableCacheTest.java | 10 +-
.../storageengine/dataregion/DataRegionTest.java | 190 +++
.../dataregion/LastFlushTimeMapTest.java | 33 +
.../compaction/AbstractCompactionTest.java | 9 +
.../cross/InsertionCrossSpaceCompactionTest.java | 16 +-
.../utils/CompactionUpdateFileCountTest.java | 66 +-
.../compaction/utils/CompactionUtilsTest.java | 2 +-
.../dataregion/memtable/TsFileProcessorTest.java | 74 +
.../read/QueryDataSourceRuntimeFilterTest.java | 76 +
.../load/active/ActiveLoadPathHelperTest.java | 146 ++
.../agent/SubscriptionConsumerAgentTest.java | 65 +
.../agent/SubscriptionTopicAgentTest.java | 85 ++
.../ConsensusLogToTabletConverterTest.java | 73 +-
.../consensus/ConsensusPrefetchingQueueTest.java | 752 ++++++++++
.../ConsensusSubscriptionCommitStateTest.java | 375 ++++-
.../ConsensusSubscriptionSetupHandlerTest.java | 141 ++
.../columnfilter/ColumnFilterBinderTest.java | 331 +++++
.../columnfilter/ColumnFilterParserTest.java | 130 ++
.../columnfilter/TabletColumnPrunerTest.java | 148 ++
...ubscriptionPipeTsFileEventBatchCleanupTest.java | 78 +
.../SubscriptionPipeTsFileEventBatchTest.java | 102 ++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../src/test/resources/iotdb-common.properties | 3 +-
.../src/test/resources/iotdb-system.properties | 3 +-
.../conf/iotdb-system.properties.template | 52 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 14 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 12 +-
.../client/request/AsyncRequestManager.java | 12 +-
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 62 +-
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../apache/iotdb/commons/disk/FolderManager.java | 5 +-
.../exception/MetadataLeaseFencedException.java} | 13 +-
.../LoggerPeriodicalLogReducer.java} | 65 +-
.../apache/iotdb/commons/memory/MemoryConfig.java | 27 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 21 +-
.../connection/UnboundedBlockingPendingQueue.java | 4 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 103 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 2 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 16 +-
.../pipe/config/constant/PipeSinkConstant.java | 10 +
.../queue/ConcurrentIterableLinkedQueue.java | 5 +-
.../AbstractSerializableListeningQueue.java | 2 +-
.../datastructure/visibility/VisibilityUtils.java | 34 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 26 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 4 +-
.../commons/pipe/resource/log/PipeLogger.java | 22 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 17 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 10 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 125 +-
.../plan/relational/planner/node/TopKNode.java | 55 +-
.../schema/table/NonCommittableTsTable.java | 5 +-
...mmittableTsTable.java => PreDeleteTsTable.java} | 15 +-
.../commons/schema/table/TableNodeStatus.java | 10 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 27 +-
.../subscription/columnfilter/ColumnMetadata.java} | 40 +-
.../meta/consumer/CommitProgressKeeper.java | 188 ++-
.../commons/subscription/meta/topic/TopicMeta.java | 2 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 46 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 9 +-
.../RegionMigrationFileRemoveRateLimiter.java} | 40 +-
.../commons/utils/RegionMigrationRateLimiter.java} | 28 +-
.../LoggerPeriodicalLogReducerTest.java} | 21 +-
.../UnboundedBlockingPendingQueueTest.java | 73 +
.../ConcurrentIterableLinkedQueueTest.java | 21 +
.../listening/AbstractPipeListeningQueueTest.java | 91 ++
.../visibility/VisibilityUtilsTest.java | 33 +-
.../meta/consumer/CommitProgressKeeperTest.java | 248 ++++
.../commons/subscription/topic/TopicDeSerTest.java | 28 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 64 +
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 7 +
.../grammar/sql/SubscriptionColumnFilter.g4 | 88 ++
iotdb-doap.rdf | 14 +-
.../src/main/thrift/confignode.thrift | 12 +-
scripts/conf/confignode-env.sh | 91 +-
scripts/conf/datanode-env.sh | 86 +-
scripts/conf/iotdb-common.sh | 117 +-
scripts/conf/windows/confignode-env.bat | 5 +-
scripts/conf/windows/datanode-env.bat | 3 +-
496 files changed, 27215 insertions(+), 3658 deletions(-)
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/handler/QueryRowLimitUtils.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/handler/QueryRowLimitUtilsTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/v1/handler/QueryDataSetHandlerTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/v2/handler/FastLastHandlerTest.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBIPv6ClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBIPv6ExternalServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileAuthIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
=> IoTDBAlignedLastQueryWithTimeFilterIT.java} (56%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/it/utils/IPv6TestUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeIPv6IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeMutualSSLIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBTopKRuntimeFilterScanPathIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableDDLHAIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBIPv6ClientIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionColumnFilterClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/tablemodel/IoTDBSubscriptionColumnFilterIT.java
create mode 100644 iotdb-client/client-py/tests/unit/test_session_node_url.py
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/config/TopicConfigTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponseTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerLifecycleTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/SubscriptionRecordHandlerTest.java
create mode 100644 iotdb-core/ainode/tests/test_config.py
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/filter/TopKRuntimeFilter.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/filter/TopKRuntimeFilterTest.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{CommitCreateTablePlan.java
=> RollbackPreDeleteTablePlan.java} (74%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/lease/ClusterCachePropagator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/lease/DataNodeContactTracker.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/lease/MetadataBroadcastVerdict.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/memory/PipeConfigNodeMemoryManager.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerCommitProgressTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/lease/ClusterCachePropagatorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/lease/DataNodeContactTrackerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/lease/MetadataBroadcastVerdictTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigRegionListenerSnapshotTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/CommitProgressSyncProcedureTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/CreateTableViewStatement.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcFactory.java}
(59%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppender.java
copy
iotdb-core/{calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/fill/identity/IdentityFill.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcRpcType.java}
(67%)
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppenderTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TreeAnalysisMutationJournal.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TopKRuntimeFilterOptimizer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/lease/MetadataLeaseManager.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{subscription/metric/SubscriptionMetrics.java
=> service/metrics/MetadataLeaseMetrics.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/BoundColumnFilter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterBinder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterEvaluator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterMatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterValidator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TabletColumnPruner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TreeViewTabletProjector.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcherLeaseTest.java
copy
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java
=>
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/DataNodeMemoryConfigTest.java
(61%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimatorPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeTabletEventTsFileBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferTabletBatchReqV2PerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTsFileHandlerCleanupTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/util/builder/PipeTsFileBuilderV2Test.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/ExternalTsFileTableScanOperatorRuntimeFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyzeRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/PartitionCacheLeaseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecutionRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LogicalPlanBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceSchemaCacheManagerLeaseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/ParallelizeGroupingTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TopKRuntimeFilterDistributedPlanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TopKRuntimeFilterTreeViewPlanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/lease/MetadataLeaseManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/lease/MetadataLeaseTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCacheLeaseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/QueryDataSourceRuntimeFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelperTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionSetupHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterBinderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParserTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/columnfilter/TabletColumnPrunerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatchCleanupTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatchTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/load/LoadAnalyzeException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/MetadataLeaseFencedException.java}
(70%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducer.java
=> log/LoggerPeriodicalLogReducer.java} (55%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/{NonCommittableTsTable.java
=> PreDeleteTsTable.java} (71%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/DescTablePlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/subscription/columnfilter/ColumnMetadata.java}
(50%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/iot/snapshot/IoTConsensusRateLimiter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/RegionMigrationFileRemoveRateLimiter.java}
(53%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/iot/snapshot/IoTConsensusRateLimiter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/RegionMigrationRateLimiter.java}
(62%)
rename
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducerTest.java
=> log/LoggerPeriodicalLogReducerTest.java} (67%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/agent/task/connection/UnboundedBlockingPendingQueueTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/queue/listening/AbstractPipeListeningQueueTest.java
create mode 100644
iotdb-core/relational-grammar/src/main/antlr4/org/apache/iotdb/db/relational/grammar/sql/SubscriptionColumnFilter.g4
