This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch opti-pipe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3d280ef67a3 [Pipe] Update dependency inventory after removing OPC UA
sink
add a6cfe257b1d Avoid size estimation for fixed-length compaction points
(#18707)
add dacf7c681f8 Expand some codes for use in the future (#18752)
add f58a52fe90c Fix WAL replay stalls on oversized entries (#18728)
add ce6c1f5f477 Fix pipe sink metrics lifecycle race (#18722)
add b2cc8b52126 Fix metrics lost after metric service restart and
conflicting metric series (#18748)
add 9e40726175d Reuse tablet device ranges during writes (#18734)
add d74b2744ed1 Fix schema region snapshot memory accounting (#18750)
add bd3109ef1ba Fix tag index query for pre-deleted timeseries (#18751)
add afb90593d1c Fix subscription TsFile deduplication and poll concurrency
(#18758)
add 864321f86a7 Fix async subscription commits after close (#18757)
add 3227bc1a219 [Subscription] Increase consensus catch-up batch size
(#18739)
add 3154bffd068 [Subscription] Prevent unsubscribe from blocking on
prefetch cleanup (#18742)
add 4092a780097 Fix pipe TsFile transfer when mod file is missing (#18756)
add 61e405bbfdb Revert "Show pre-deleted table schemas and improve write
errors (#18626)" (#18762)
add f510a924968 Fix ordering propagation around table and window functions
(#18749)
add 50d86cf4161 Fix flaky heartbeat executor bound test (#18773)
add 825bf9e6b8b Stop data region write retry promptly (#18730)
add 94694d92f25 Avoid redundant TsFile table schema registration (#18731)
add daf9dd8d771 Reject duplicate schema region IDs during recovery (#18754)
add 166883a1b2e Fix semantic error for unsupported table INSERT time
expressions (#18759)
add f8bfcffc9ba Fix subscription stalls after consumer disconnect (#18760)
add ef9bb521ccf Fix subscription cache memory configuration (#18761)
add abd499334f0 [Subscription] Bound pending WAL gap replay per round
(#18766)
add 8f1bed8246c [Subscription] Consolidate poll queue fixes (#18771)
add 5d389dd6e86 Fix subscription WAL retention at replay cursor (#18769)
add 5a9c6b9f293 Fix SHOW TTL wildcard path scope (#18763)
add ec72c599ce6 Show pre-delete tables in SHOW TABLES and reject
modifications on them (#18770)
add 0c9a5ee0916 Optimize tag index timeseries lookup (#18753)
add 2f9f9cab1b7 Fix TTL expired data ratio in settle compaction (#18777)
add b777d3c3f3d [Subscription] Reuse uncovered committed WAL retention
boundary (#18778)
add e163f3bc802 Stabilize subscription heartbeat executor test (#18782)
add df27bbc5001 Fix table delete routing to region leaders (#18779)
add acb801e163e [Subscription] Prevent consumers from idling on dry
regions (#18738)
add 0c9fb83974f [Fix] Prevent silent subscription data loss on WAL replay
gaps (#18741)
add ce14b310e1d [Subscription] Flush lingering batch before WAL gap retry
(#18785)
add bbe63644769 Revert "[Fix] Prevent silent subscription data loss on WAL
replay gaps (#18741)" (#18786)
add 5756dc831ae Build: upgrade Develocity Maven extension (#18790)
add 40e7ce62936 Reject truncated Thrift containers before allocation
(#18631)
add 28c193871de Update extra-enforcer-rules to 1.12.1 and drop its
maven-dependency-tree pin (#18796)
add a1c0e90b546 Fix nonexistent file paths in Python client README and
correct doc typos (#18797)
add 3a42dddc3f6 Upgrade Docker base image to eclipse-temurin:17-jre-jammy
(#18795)
add d20082b1615 [Misc] Add generic extension points to reduce cross-branch
conflicts (#18683)
add 4473a133d08 Fix table rename on a DataNode that missed the pre-release
(#18800)
add 48233ea92dd [Fix] Isolate FileReaderManager reader I/O with per-file
locks (#18788)
add 59d9e3e10ad Bump at.yawk.lz4:lz4-java from 1.11.1 to 1.11.4 (#18798)
add 620be2861b8 Bump com.fasterxml.jackson.core:jackson-core from 2.18.9
to 2.18.11 (#18789)
add eb0e3f1f208 Fix duplicate DataRegion scheduling after recovery (#18803)
add 1a834815784 Fix read lock leak in disk usage statistics (#18807)
add 94f99d6516a Extend the node state machine and persist node statuses
(#18801)
add cb0269d9fde Standardize ConfigRegionStateMachine log messages (#18811)
add 99a3e06c76b [Fix] Preserve absent local search index during
subscription WAL replay (#18805)
add 83f6428629d Fix subscription WAL replay cursor boundaries (#18810)
add 24fb54f7e77 Bump Thrift to 0.25.0 (#18793)
add 21d53dd015c Bound subscription memory borrowing and report admission
failures (#18812)
add b94aa09ab66 [Fix] Prevent consensus subscription teardown from
blocking unsubscribe (#18804)
add 054f5dedae5 [Subscription] Report retained WAL file gaps and retry
transient reads (#18818)
add f16e5b36fb5 Eliminate OPC UA sink test port allocation race (#18817)
add 741a13a5d24 Remove some printed errMsg when stop DN (#18799)
add abcbf2ed525 [Subscription] Release exhausted TsFile parsers before
batch ACK (#18820)
add 6819c8beb9f [Fix] Remap failed-measurement indices when reordering
insert columns (#18819)
add e3c4a4e5178 [Pipe] Support region-level realtime downgrading (#18441)
add 03988521b3a Merge origin/master into opti-pipe and resolve OPC UA
removal conflicts
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 12 +-
.mvn/extensions.xml | 2 +-
LICENSE-binary | 4 +-
docker/ReadMe.md | 4 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 12 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 31 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 60 +-
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 743 ++++++++++++
.../it/cluster/IoTDBNodeStatusPersistenceIT.java | 379 ++++++
.../confignode/it/cluster/NodeStatusTestAgent.java | 203 ++++
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 3 +-
.../it/partition/IoTDBPartitionCreationIT.java | 58 +-
.../it/partition/IoTDBPartitionDurableIT.java | 49 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 68 ++
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 6 +-
.../it/db/it/IoTDBDeletionTableClusterIT.java | 152 +++
.../relational/it/db/it/IoTDBInsertTableIT.java | 117 ++
.../it/db/it/IoTDBOrderingPropertyIT.java | 486 ++++++++
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 70 +-
.../it/db/it/IoTDBWindowFunction3IT.java | 6 +-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 38 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 77 ++
...ableAggregationQueryWithNetworkPartitionIT.java | 5 +-
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 3 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 1 +
.../iotdb/session/it/IoTDBConnectionsIT.java | 53 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 21 +-
...TDBConsensusSubscriptionUnsubscribeTableIT.java | 253 ++++
.../event/dml/insertion/TsFileInsertionEvent.java | 5 +
iotdb-client/client-py/README.md | 6 +-
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../org/apache/iotdb/rpc/NonOpenTransport.java | 6 +
.../rpc/TCompressedElasticFramedTransport.java | 4 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 74 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 26 +
.../iotdb/rpc/TElasticFramedTransportReadTest.java | 266 ++++
.../iotdb/rpc/TElasticFramedTransportTest.java | 101 ++
.../base/AbstractSubscriptionConsumer.java | 31 +-
...SubscriptionConsumerHeartbeatIsolationTest.java | 39 +-
.../base/SubscriptionConsumerLifecycleTest.java | 91 ++
.../operator/RowReferenceTsBlockManager.java | 12 +-
.../process/AbstractLinearFillOperator.java | 15 +-
.../process/TableLinearFillWithGroupOperator.java | 18 +-
.../process/TableNextFillWithGroupOperator.java | 5 +
.../operator/process/TableStreamSortOperator.java | 4 +-
.../process/window/TopKRankingOperator.java | 12 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 65 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 17 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 9 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 68 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 17 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 18 +-
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 4 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 7 +-
.../consensus/request/ConfigPhysicalPlan.java | 12 +-
.../consensus/request/ConfigPhysicalPlanType.java | 10 +-
.../request/ConfigPhysicalPlanVisitor.java | 8 +
...sionInfoPlan.java => UpdateNodeStatusPlan.java} | 57 +-
.../table/RollbackPreAlterColumnDataTypePlan.java | 61 -
...Plan.java => SetTableColumnPropertiesPlan.java} | 34 +-
.../partition/GetRegionGroupsByTimeResp.java | 25 +
.../statemachine/ConfigRegionStateMachine.java | 16 +-
.../iotdb/confignode/manager/ConfigManager.java | 161 +--
.../apache/iotdb/confignode/manager/IManager.java | 18 +-
.../iotdb/confignode/manager/ProcedureManager.java | 34 +-
.../confignode/manager/RetryFailedTasksThread.java | 3 +-
.../iotdb/confignode/manager/load/LoadManager.java | 76 +-
.../manager/load/balancer/RegionBalancer.java | 12 +-
.../manager/load/cache/AbstractLoadCache.java | 9 +-
.../confignode/manager/load/cache/LoadCache.java | 140 ++-
.../load/cache/consensus/ConsensusGroupCache.java | 3 +-
.../load/cache/node/AINodeHeartbeatCache.java | 48 -
.../manager/load/cache/node/BaseNodeCache.java | 84 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 39 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 57 +-
.../load/cache/node/NodeHeartbeatSample.java | 7 +-
.../manager/load/cache/node/NodeStatistics.java | 17 +
.../manager/load/cache/region/RegionCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 2 +-
.../manager/load/service/StatisticsService.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 25 +-
.../manager/partition/PartitionManager.java | 3 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 20 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 18 +-
.../metric/sink/PipeConfigRegionSinkMetrics.java | 17 +-
.../source/PipeConfigRegionSourceMetrics.java | 17 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 26 +
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 7 +
.../pipe/source/ConfigRegionListeningFilter.java | 2 +
.../manager/schema/ClusterSchemaManager.java | 103 +-
.../runtime/SubscriptionRuntimeCoordinator.java | 7 +-
.../persistence/executor/ConfigPlanExecutor.java | 86 +-
.../confignode/persistence/node/NodeInfo.java | 115 +-
.../schema/CNPhysicalPlanGenerator.java | 48 +-
.../persistence/schema/CNSnapshotFileType.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 108 +-
.../confignode/persistence/schema/ConfigMTree.java | 227 ++--
.../procedure/env/ConfigNodeProcedureEnv.java | 7 +-
.../procedure/env/RegionMaintainHandler.java | 2 +-
.../procedure/env/RemoveDataNodeHandler.java | 71 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 1 +
.../impl/node/RemoveDataNodesProcedure.java | 6 +-
.../procedure/impl/schema/SchemaUtils.java | 26 +-
.../table/AbstractAlterOrDropTableProcedure.java | 19 +
...re.java => AbstractSetPropertiesProcedure.java} | 71 +-
.../table/AlterTableColumnDataTypeProcedure.java | 78 +-
.../impl/schema/table/CreateTableProcedure.java | 16 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 2 +-
.../impl/schema/table/RenameTableProcedure.java | 2 +-
.../table/SetTableColumnPropertiesProcedure.java | 107 ++
.../schema/table/SetTablePropertiesProcedure.java | 218 +---
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../confignode/service/ConfigNodeShutdownHook.java | 162 ++-
.../heartbeat/DataNodeHeartbeatHandlerTest.java | 100 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 82 +-
.../manager/ClusterSchemaManagerTest.java | 89 ++
.../manager/ConfigManagerShutdownReportTest.java | 161 +++
.../confignode/manager/ProcedureManagerTest.java | 25 +
.../manager/RetryFailedTasksThreadTest.java | 107 ++
.../confignode/manager/load/LoadManagerTest.java | 115 +-
.../manager/load/balancer/RegionBalancerTest.java | 144 +++
.../router/priority/GreedyPriorityTest.java | 2 +-
.../priority/LeaderPriorityBalancerTest.java | 2 +-
.../load/cache/ConsensusGroupCacheTest.java | 2 +-
.../load/cache/LoadCacheNodeStatusTest.java | 336 +++++
.../cache/LoadCachePersistedNodeStatusTest.java | 898 ++++++++++++++
.../manager/load/cache/NodeCacheTest.java | 228 +++-
.../manager/node/NodeManagerStatusReasonTest.java | 133 ++
.../metric/PipeConfigNodeMetricsRestartTest.java | 184 +++
.../SubscriptionRuntimeCoordinatorTest.java | 119 ++
.../persistence/CNPhysicalPlanGeneratorTest.java | 20 +
.../iotdb/confignode/persistence/NodeInfoTest.java | 269 +++++
.../persistence/schema/ClusterSchemaInfoTest.java | 119 ++
.../persistence/schema/ConfigMTreeTest.java | 64 +-
.../persistence/schema/TablePreDeleteTest.java | 368 ------
.../procedure/env/ConfigNodeProcedureEnvTest.java | 93 ++
.../procedure/env/RegionMaintainHandlerTest.java | 68 ++
.../impl/node/RemoveDataNodePersistenceTest.java | 581 +++++++++
.../procedure/impl/schema/SchemaUtilsTest.java | 91 ++
.../AlterTableColumnDataTypeProcedureTest.java | 171 ---
.../schema/table/CreateTableProcedureTest.java | 39 -
.../service/ConfigNodeShutdownHookTest.java | 346 ++++++
iotdb-core/consensus/pom.xml | 5 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 104 +-
.../subscription/SubscriptionQueueAdmission.java | 18 +-
.../subscription/SubscriptionQueueRegistry.java | 60 +-
.../SubscriptionQueueRejectionReason.java | 42 +
.../SubscriptionWalRetentionCalculator.java | 10 +-
.../consensus/pipe/IoTConsensusV2ServerImpl.java | 5 +
.../pipe/metric/IoTConsensusV2ServerMetrics.java | 3 -
.../consensus/ratis/metrics/CounterProxy.java | 8 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 34 +-
.../ratis/metrics/MetricRegistryManager.java | 14 +
.../consensus/ratis/metrics/RatisMetricSet.java | 8 +-
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 7 +-
.../LogDispatcherThreadMetricsTest.java | 146 +++
.../metric/IoTConsensusV2ServerMetricsTest.java | 107 ++
.../ratis/metrics/RatisMetricSetTest.java | 134 ++
iotdb-core/datanode/pom.xml | 18 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 3 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 69 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 3 +
.../iotdb/db/i18n/StorageEngineMessages.java | 11 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 66 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 3 +
.../iotdb/db/i18n/StorageEngineMessages.java | 11 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 14 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +
.../dataregion/DataRegionStateMachine.java | 8 +-
.../AllowAllLBACAccessControl.java} | 38 +-
.../apache/iotdb/db/lbac/ILBACAccessControl.java | 74 ++
.../agent/task/connection/PipeEventCollector.java | 10 +
.../common/tablet/PipeRawTabletInsertionEvent.java | 31 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 201 ++-
.../overview/PipeDataNodeSinglePipeMetrics.java | 20 +-
.../overview/PipeTsFileToTabletsMetrics.java | 16 +-
.../metric/processor/PipeProcessorMetrics.java | 19 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 16 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 16 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 16 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 19 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 13 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 20 +-
.../request/PipeTransferTabletBatchReqV2.java | 3 +
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 3 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 109 +-
.../async/handler/PipeTransferTsFileHandler.java | 100 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 3 +-
.../PipeRealtimeDataRegionHybridSource.java | 668 +++++++++-
.../realtime/PipeRealtimeDataRegionSource.java | 35 +
.../PipeRealtimeDataRegionTsFileSource.java | 150 ++-
.../handler/RPCServiceThriftHandlerMetrics.java | 37 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 35 +-
.../fragment/FakedFragmentInstanceContext.java | 84 +-
.../fragment/FragmentInstanceContext.java | 181 ++-
.../fragment/FragmentInstanceExecution.java | 11 +-
.../InformationSchemaContentSupplierFactory.java | 67 +-
.../execution/schedule/DriverScheduler.java | 9 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../plan/analyze/schema/SchemaValidator.java | 56 +-
.../execution/config/TableConfigTaskVisitor.java | 69 ++
.../config/executor/ClusterConfigTaskExecutor.java | 80 +-
.../config/executor/IConfigTaskExecutor.java | 9 +
.../config/metadata/ShowClusterDetailsTask.java | 63 +-
.../execution/config/metadata/ShowClusterTask.java | 40 +-
.../config/metadata/ShowConfigNodesTask.java | 28 +-
.../config/metadata/ShowDataNodesTask.java | 30 +-
...java => AlterTableSetColumnPropertiesTask.java} | 18 +-
.../AdditionalInformationSchemaProvider.java | 59 +
...ditionalInformationSchemaProviderRegistry.java} | 29 +-
.../relational/metadata/TableMetadataImpl.java | 11 +-
.../fetcher/TableHeaderSchemaValidator.java | 41 +-
.../distribute/TableDistributedPlanGenerator.java | 594 ++++++++-
.../DataNodeLocationSupplierFactory.java | 9 +
.../planner/optimizations/SortElimination.java | 65 +-
.../optimizations/TableFunctionOrdering.java | 79 ++
.../TransformAggregationToStreamable.java | 5 +-
.../optimizations/TransformSortToStreamSort.java | 45 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/DefaultTraversalVisitor.java | 9 +
...ColumnComment.java => SetColumnProperties.java} | 76 +-
.../plan/relational/sql/parser/AstBuilder.java | 16 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 25 +
.../plan/statement/crud/InsertBaseStatement.java | 46 +
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 23 +-
.../schemaengine/metric/SchemaEngineMemMetric.java | 7 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 7 +-
.../rescon/MemSchemaEngineStatistics.java | 4 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 10 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 32 +-
.../schemaengine/schemaregion/tag/TagManager.java | 55 +-
.../db/schemaengine/table/DataNodeTableCache.java | 117 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../iotdb/db/service/DataNodeShutdownHook.java | 6 +-
.../iotdb/db/service/metrics/CacheMetrics.java | 17 +
.../db/service/metrics/DataNodeMetricsHelper.java | 1 +
.../iotdb/db/service/metrics/WritingMetrics.java | 80 +-
.../db/service/metrics/file/TsFileMetrics.java | 22 +
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 12 +-
.../dataregion/DataRegionMetrics.java | 49 +-
.../utils/writer/AbstractCompactionWriter.java | 10 +-
.../schedule/CompactionScheduleTaskManager.java | 10 +-
.../selector/impl/SettleSelectorImpl.java | 5 +-
.../dataregion/memtable/AbstractMemTable.java | 32 +-
.../dataregion/memtable/IMemTable.java | 10 +
.../dataregion/memtable/TsFileProcessor.java | 102 +-
.../memtable/TsFileProcessorInfoMetrics.java | 55 +-
.../dataregion/read/control/FileReaderManager.java | 698 +++++++----
.../dataregion/tsfile/TsFileLock.java | 27 +-
.../dataregion/utils/DiskUsageStatisticUtil.java | 12 +-
.../dataregion/wal/buffer/WALBuffer.java | 29 +-
.../wal/checkpoint/CheckpointManager.java | 4 +-
.../dataregion/wal/io/WALByteBufReader.java | 17 +-
.../storageengine/dataregion/wal/node/WALNode.java | 7 +-
.../load/memory/LoadTsFileMemoryBlock.java | 20 +-
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 6 +
.../ActiveLoadingFilesNumberMetricsSet.java | 16 +-
.../load/metrics/LoadTsFileMemMetricSet.java | 19 +-
.../agent/SubscriptionBrokerAgent.java | 8 +
.../agent/SubscriptionConsumerAgent.java | 147 ++-
.../agent/SubscriptionReceiverAgent.java | 12 +
.../broker/ConsensusSubscriptionBroker.java | 58 +-
.../subscription/broker/ISubscriptionBroker.java | 3 +
.../db/subscription/broker/SubscriptionBroker.java | 14 +-
.../broker/SubscriptionPrefetchingQueue.java | 103 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 28 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 11 +-
.../consensus/ConsensusPrefetchingQueue.java | 642 ++++++++--
.../broker/consensus/ProgressWALIterator.java | 301 ++++-
.../batch/SubscriptionPipeTabletEventBatch.java | 21 +-
.../event/cache/SubscriptionPollResponseCache.java | 24 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 122 +-
.../SubscriptionPrefetchingQueueMetrics.java | 55 +-
.../receiver/SubscriptionReceiver.java | 5 +
.../receiver/SubscriptionReceiverV1.java | 15 +
.../resource/SubscriptionMemoryManager.java | 335 ++++-
.../ConsensusSubscriptionPrefetchExecutor.java | 10 +
.../task/subtask/ConsensusPrefetchSubtask.java | 1 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 9 +
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 84 --
.../org/apache/iotdb/db/auth/entity/UserTest.java | 53 -
.../dataregion/DataRegionStateMachineTest.java | 53 +-
.../schemaRegion/SchemaRegionManagementTest.java | 38 +-
.../db/pipe/metric/PipeMetricsRestartTest.java | 426 +++++++
.../PipeSchemaRegionListenerMetricsTest.java | 116 ++
.../metric/sink/PipeDataRegionSinkMetricsTest.java | 98 ++
.../thrift/async/IoTDBDataRegionAsyncSinkTest.java | 49 +
.../PipeTransferTsFileHandlerCleanupTest.java | 56 +
.../db/pipe/source/PipeRealtimeExtractTest.java | 1277 +++++++++++++++++++-
.../DataNodeInternalRPCServiceImplDiskTest.java | 43 +-
...eInternalRPCServiceImplSetSystemStatusTest.java | 91 ++
.../execution/exchange/SourceHandleTest.java | 80 ++
.../fragment/FileReaderReferenceLifecycleTest.java | 189 +++
.../RegionQueryInitializationLockTest.java | 280 +++++
.../fragment/RegionScanTimeSliceTest.java | 96 ++
.../process/TableStreamSortOperatorTest.java | 63 +
.../process/fill/GroupedFillOperatorTest.java | 174 +++
.../process/window/TopKRankingOperatorTest.java | 75 +-
.../metadata/ShowClusterDetailsTaskTest.java | 172 +++
.../config/metadata/ShowClusterTaskTest.java | 168 +++
.../config/metadata/ShowConfigNodesTaskTest.java | 121 ++
.../config/metadata/ShowDataNodesTaskTest.java | 114 ++
.../plan/relational/analyzer/TreeViewTest.java | 5 -
.../fetcher/TableHeaderSchemaValidatorTest.java | 251 ----
.../plan/relational/planner/PlanTester.java | 6 +-
.../planner/WindowFunctionOptimizationTest.java | 12 +-
.../OrderingPropertyPropagationTest.java | 481 ++++++++
.../optimizations/TableFunctionSortTest.java | 263 ++++
.../crud/InsertStatementPartialInsertTest.java | 28 +
.../iotdb/db/schemaengine/SchemaEngineTest.java | 57 +
.../metric/SchemaMemMetricTableTest.java | 133 ++
.../tag/TagManagerPerformanceTest.java | 258 ++++
.../schemaregion/tag/TagManagerTest.java | 64 +
.../schemaengine/table/DataNodeTableCacheTest.java | 249 ++--
.../metrics/DataNodeMetricsRestartTest.java | 290 +++++
.../db/service/metrics/file/TsFileMetricsTest.java | 148 +++
.../buffer/TimeSeriesMetadataCacheTest.java | 4 +-
.../dataregion/DatabaseMemMetricsTest.java | 144 +++
.../utils/writer/AbstractCompactionWriterTest.java | 17 +-
.../TabletDeviceRangeReusePerformanceTest.java | 283 +++++
.../dataregion/memtable/TsFileProcessorTest.java | 110 ++
...FileTableSchemaRegistrationPerformanceTest.java | 230 ++++
.../control/FileReaderManagerConcurrencyTest.java | 871 +++++++++++++
.../dataregion/tsfile/TsFileLockTest.java | 108 ++
.../dataregion/utils/TableDiskUsageTest.java | 8 +
.../dataregion/wal/buffer/WALBufferCommonTest.java | 27 +
.../wal/buffer/WALBufferRollRecoveryTest.java | 4 +-
.../dataregion/wal/io/WALFileTest.java | 34 +
.../rescon/disk/FolderManagerTest.java | 57 +-
.../agent/SubscriptionConsumerAgentTest.java | 114 ++
.../agent/SubscriptionReceiverAgentTest.java | 51 +
...onsensusSubscriptionBrokerPayloadLimitTest.java | 67 +
.../SubscriptionBrokerAgentPayloadLimitTest.java | 14 +
...sFileDeduplicationBlockingPendingQueueTest.java | 68 ++
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 249 +++-
.../ConsensusPrefetchingQueueSeekTest.java | 241 ++++
.../consensus/ConsensusPrefetchingQueueTest.java | 947 ++++++++++++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 19 +-
.../broker/consensus/ProgressWALIteratorTest.java | 375 +++++-
.../SubscriptionPipeTabletEventBatchTest.java | 256 ++++
.../cache/SubscriptionPollResponseCacheTest.java | 60 +
...susSubscriptionPrefetchingQueueMetricsTest.java | 88 ++
.../metric/SubscriptionMetricsRestartTest.java | 188 +++
.../receiver/SubscriptionReceiverV1Test.java | 22 +-
.../resource/SubscriptionMemoryManagerTest.java | 108 ++
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 86 +-
.../metrics/metricsets/system/SystemMetrics.java | 13 +-
.../resources/conf/edge/iotdb-system.properties | 1 +
.../conf/iotdb-system.properties.template | 35 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 12 +-
.../apache/iotdb/commons/i18n/LBACMessages.java} | 27 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 12 +-
.../apache/iotdb/commons/i18n/LBACMessages.java} | 27 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 64 -
.../org/apache/iotdb/commons/auth/entity/User.java | 64 -
.../commons/auth/role/LocalFileRoleAccessor.java | 69 +-
.../commons/auth/user/LocalFileUserAccessor.java | 6 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 102 +-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../commons/concurrent/ThreadPoolMetrics.java | 74 +-
.../WrappedScheduledExecutorService.java | 4 +-
.../WrappedSingleThreadExecutorService.java | 4 +-
.../WrappedSingleThreadScheduledExecutor.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 63 +-
.../iotdb/commons/conf/CommonDescriptor.java | 16 +-
.../apache/iotdb/commons/disk/FolderManager.java | 14 +-
.../commons/disk/strategy/DirectoryStrategy.java | 4 +-
.../commons/enums/HandleSystemErrorStrategy.java | 6 +-
.../exception/table/ColumnInAlterException.java | 40 -
.../exception/table/ColumnInDeletionException.java | 40 -
.../exception/table/TableInDeletionException.java | 4 +-
.../commons/lbac/LBACAccessDeniedException.java | 56 +
.../iotdb/commons/lbac/LBACRuntimeException.java} | 15 +-
.../apache/iotdb/commons/lbac/RequiredLabels.java | 79 ++
.../operation/LabelAccessType.java} | 8 +-
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../pipe/metric/PipeEventCommitMetrics.java | 20 +-
.../execution/MemoryEstimationHelper.java | 13 +
.../function/TableBuiltinTableFunction.java | 34 +-
.../plan/relational/metadata/ColumnSchema.java | 13 +-
.../schema/column/ColumnHeaderConstant.java | 2 +
.../table/AlterOrDropTableOperationType.java | 5 +-
.../commons/schema/table/InformationSchema.java | 41 +
.../apache/iotdb/commons/schema/table/TsTable.java | 2 +
.../service/metric/JvmGcMonitorMetrics.java | 38 +-
.../commons/service/metric/MetricService.java | 13 +-
.../iotdb/commons/service/metric/enums/Metric.java | 13 +
.../iotdb/commons/service/metric/enums/Tag.java | 1 +
.../iotdb/commons/cluster/NodeStatusTest.java | 91 ++
.../commons/concurrent/ThreadPoolMetricsTest.java | 157 +++
.../iotdb/commons/conf/CommonConfigTest.java | 230 +++-
...ubscriptionCacheMemoryUsagePercentageTest.java} | 24 +-
.../pipe/metric/PipeEventCommitMetricsTest.java | 99 ++
.../service/metric/JvmGcMonitorMetricsTest.java | 72 ++
.../service/metric/MetricServiceRestartTest.java | 218 ++++
.../src/main/thrift/confignode.thrift | 21 +-
pom.xml | 15 +-
419 files changed, 27502 insertions(+), 4832 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusFailoverIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusPersistenceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/NodeStatusTestAgent.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBOrderingPropertyIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionUnsubscribeTableIT.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportReadTest.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/{UpdateVersionInfoPlan.java
=> UpdateNodeStatusPlan.java} (56%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/RollbackPreAlterColumnDataTypePlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{SetTablePropertiesPlan.java
=> SetTableColumnPropertiesPlan.java} (67%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/{SetTablePropertiesProcedure.java
=> AbstractSetPropertiesProcedure.java} (76%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTableColumnPropertiesProcedure.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/client/async/handlers/heartbeat/DataNodeHeartbeatHandlerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerShutdownReportTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/RetryFailedTasksThreadTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/RegionBalancerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCacheNodeStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCachePersistedNodeStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerStatusReasonTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetricsRestartTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/runtime/SubscriptionRuntimeCoordinatorTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/TablePreDeleteTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnvTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodePersistenceTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/SchemaUtilsTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedureTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/service/ConfigNodeShutdownHookTest.java
copy
external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/Message.java =>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueAdmission.java
(71%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRejectionReason.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherThreadMetricsTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetricsTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSetTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner/ir/ExpressionNodeInliner.java
=> lbac/AllowAllLBACAccessControl.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/lbac/ILBACAccessControl.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableCommentColumnTask.java
=> AlterTableSetColumnPropertiesTask.java} (77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProvider.java
copy
iotdb-core/{calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProviderRegistry.java}
(57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionOrdering.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{SetColumnComment.java
=> SetColumnProperties.java} (63%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/RoleTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/UserTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/PipeMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionListenerMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/sink/PipeDataRegionSinkMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplSetSystemStatusTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FileReaderReferenceLifecycleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionQueryInitializationLockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionScanTimeSliceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/GroupedFillOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterDetailsTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowConfigNodesTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowDataNodesTaskTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/OrderingPropertyPropagationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionSortTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/SchemaEngineTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/metric/SchemaMemMetricTableTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/DataNodeMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/file/TsFileMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DatabaseMemMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TabletDeviceRangeReusePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileTableSchemaRegistrationPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/control/FileReaderManagerConcurrencyTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileLockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueueTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueSeekTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCacheTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/metric/SubscriptionMetricsRestartTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/query/OutOfTTLException.java
=>
node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/LBACMessages.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/query/OutOfTTLException.java
=>
node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/LBACMessages.java}
(51%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/ColumnInAlterException.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/ColumnInDeletionException.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACAccessDeniedException.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACRuntimeException.java}
(72%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/RequiredLabels.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{auth/entity/ModelType.java
=> lbac/operation/LabelAccessType.java} (89%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/cluster/NodeStatusTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/concurrent/ThreadPoolMetricsTest.java
copy
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{sync/TsFilePipeInfoTest.java
=> conf/CommonDescriptorSubscriptionCacheMemoryUsagePercentageTest.java} (56%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/metric/PipeEventCommitMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/JvmGcMonitorMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricServiceRestartTest.java
