This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5b25b053948 reset storage in RecoverReadTest
add 9a09c707a37 [IOTDB-6316] Fix potential concurrent bug between
compaction and load (#12244)
add 8b28a0e72f0 Subscription: stop meta sync properly when no
topic/consumer group (#12247)
add f34ae60d955 Subscription: initialize the subscription session and
consumer & Pipe: fix data points loss caused by unclosed tsfile listened by
historical extractor (#12228)
add 81f1cd725d2 Fix uncompress byte buffer in RepairDataFileScanUtil
add cdf002fb914 Pipe: Support tsfile mod & schema region snapshot & config
region snapshot transferring logic (#11998)
add 49e199ef0ea fix: consider more general type of nodes in optimization
above LimitNode (#12240)
add db9530568d3 Forcibly take snapshot when upgrade procedure WAL (#12252)
add 7f88de31cb2 Modify compaction task priority comparator (#12255)
add e3d48b5e1a0 Add the import and export function of SQl files on the
basis of CSV import and export scripts (#12248)
add 4d826ef2a64 invert insertRecords to insertTablets (#12113)
add d8ac76ebe8c Fix the mistaken argument in LZ4Uncompressor
add cd6ba732a42 Subscription: fix some issues on DN and session & improve
IT (#12254)
add 611f203847f Pipe: Added handshake logic when config receiver is reset
due to receiver side DataNode redirection & Enhance IT & Refactor (#12256)
add d46dd660a67 Region migration related work (#12246)
add 4165e4c95f5 [IOTDB-6307] GCR algorithm for multi-database (#12183)
add b619e418f7b Revert "Region migration related work (#12246)"
add eab1df34714 Region migration related work (#12259)
add 2865e8a4233 [IOTDB-6308] CFD algorithm for multi-database (#12184)
add edf657301e0 Ignore view number in cluster series limit
add 1b9f4f79de0 Revert the change of integration-test module
add 26dc03b32d9 Pipe: refactor package structure (#12267)
add 2990412b8bb Fix Load TsFile with extend template & add template check
for internalCreateTimeSeriesStatement (#12266)
add d859d5f0c9b Pipe: Fix schema region snapshot may not be listened when
DataNode restarts (#12270)
add eee977c28b9 Subscription: fix null ByteBuffer when transferring
SerializedEnrichedEvent (#12273)
add fd1d6ca0683 remove Repair Data ClusterIT
add b22e062f7d5 Merge branch 'master' into native_raft
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 82 ++-
.../apache/iotdb/SubscriptionSessionExample.java | 124 +++--
integration-test/pom.xml | 34 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 15 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 11 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 10 +
...2.java => MultiClusterIT2AutoCreateSchema.java} | 2 +-
...java => MultiClusterIT2ManualCreateSchema.java} | 2 +-
...erIT2.java => MultiClusterIT2Subscription.java} | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +
...oTDBMultiDBRegionGroupLeaderDistributionIT.java | 154 ++++++
...a => IoTDBRegionGroupLeaderDistributionIT.java} | 123 +++--
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 119 +++--
.../IoTDBRegionMigrateReliabilityITFramework.java} | 431 +++++++++-------
.../CoordinatorRemoveRemotePeerCrashIT.java | 51 ++
.../IoTDBRegionMigrateDataNodeCrashIT.java | 72 +++
.../pass/IoTDBRegionMigrateConfigNodeCrashIT.java | 92 ++++
.../pass/IoTDBRegionMigrateNormalIT.java | 47 +-
.../pass/IoTDBRegionMigrateOtherIT.java | 45 ++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 67 +++
.../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 3 +-
.../scalar/IoTDBSubStringFunctionIT.java | 36 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 23 +
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 16 +-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 171 ++++---
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 76 +--
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 222 ++++-----
.../autocreate/IoTDBPipeConnectorParallelIT.java | 22 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 36 +-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 204 ++++----
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 51 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 184 +++----
.../pipe/it/autocreate/IoTDBPipeNullValueIT.java | 33 +-
.../it/autocreate/IoTDBPipePatternFormatIT.java | 61 +--
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 35 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 106 ++--
.../it/autocreate/IoTDBPipeSwitchStatusIT.java | 62 +--
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 222 +++++----
.../pipe/it/manual/AbstractPipeDualManualIT.java | 16 +-
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 54 +-
.../pipe/it/manual/IoTDBPipeManualConflictIT.java | 58 ++-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 239 +++++++++
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 40 +-
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 46 +-
.../it/manual/IoTDBPipeMultiSchemaRegionIT.java | 35 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 10 +-
.../pipe/it/single/IoTDBPipeSingleEnvDemoIT.java | 10 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 37 ++
.../subscription/it/IoTDBSubscriptionBasicIT.java | 245 ---------
.../it/IoTDBSubscriptionConsumerGroupIT.java | 342 -------------
.../subscription/it/IoTDBSubscriptionTopicIT.java | 250 ----------
.../it/dual/AbstractSubscriptionDualIT.java} | 4 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 555 +++++++++++++++++++++
.../it/dual/IoTDBSubscriptionTopicIT.java | 376 ++++++++++++++
.../it/local/IoTDBSubscriptionBasicIT.java | 157 ++++++
.../it/local/IoTDBSubscriptionIdempotentIT.java | 162 ++++++
.../it/local/IoTDBSubscriptionRestartIT.java | 200 ++++++++
...{ExportCsvTestIT.java => ExportDataTestIT.java} | 59 ++-
...{ImportCsvTestIT.java => ImportDataTestIT.java} | 6 +-
.../org/apache/iotdb/pipe/api/PipeExtractor.java | 2 +-
.../event/dml/insertion/TabletInsertionEvent.java | 12 +-
iotdb-client/cli/pom.xml | 4 +
.../tools/{export-csv.bat => export-data.bat} | 2 +-
.../tools/{export-csv.sh => export-data.sh} | 2 +-
.../tools/{import-csv.bat => import-data.bat} | 2 +-
.../tools/{import-csv.sh => import-data.sh} | 2 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 8 +-
...{AbstractCsvTool.java => AbstractDataTool.java} | 7 +-
.../iotdb/tool/{ExportCsv.java => ExportData.java} | 178 ++++++-
.../iotdb/tool/{ImportCsv.java => ImportData.java} | 64 ++-
...riteCsvFileTest.java => WriteDataFileTest.java} | 6 +-
.../java/org/apache/iotdb/isession/ISession.java | 19 -
.../apache/iotdb/isession/ISessionDataSet.java} | 15 +-
.../org/apache/iotdb/isession/SessionConfig.java | 5 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../rpc/subscription}/SubscriptionException.java | 15 +-
.../{payload => }/config/ConsumerConfig.java | 2 +-
.../{payload => }/config/ConsumerConstant.java | 23 +-
.../{payload => }/config/TopicConfig.java | 2 +-
.../{payload => }/config/TopicConstant.java | 2 +-
.../payload/{response => }/EnrichedTablets.java | 16 +-
.../payload/request/PipeSubscribeHandshakeReq.java | 2 +-
.../payload/request/PipeSubscribeHeartbeatReq.java | 3 +-
.../payload/request/PipeSubscribePollReq.java | 14 +-
.../response/PipeSubscribeHandshakeResp.java | 35 +-
.../payload/response/PipeSubscribePollResp.java | 25 +-
.../java/org/apache/iotdb/session/Session.java | 285 +++++++++--
.../apache/iotdb/session/SessionConnection.java | 71 +--
.../org/apache/iotdb/session/pool/SessionPool.java | 11 +
.../subscription/ConsumerHeartbeatWorker.java | 53 ++
.../subscription/PullConsumerAutoCommitWorker.java | 64 +++
.../session/subscription/SubscriptionConsumer.java | 279 +++++++++++
.../session/subscription/SubscriptionMessage.java | 85 ++++
.../subscription/SubscriptionMessagePayload.java | 4 +-
.../session/subscription/SubscriptionProvider.java | 91 ++++
.../subscription/SubscriptionPullConsumer.java | 310 ++++++++++++
.../subscription/SubscriptionPushConsumer.java | 39 +-
.../session/subscription/SubscriptionSession.java | 185 +++++++
.../SubscriptionSessionConnection.java | 167 +++++++
.../subscription/SubscriptionSessionDataSet.java | 175 +++++++
.../subscription/SubscriptionSessionDataSets.java | 53 ++
.../session/subscription/model/Subscription.java | 41 +-
.../iotdb/session/subscription/model/Topic.java} | 28 +-
.../iotdb/session/SessionCacheLeaderTest.java | 6 +-
.../java/org/apache/iotdb/session/SessionTest.java | 5 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +
.../flink/sql/function/IoTDBCDCSourceFunction.java | 1 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 4 +-
.../confignode/conf/ConfigNodeDescriptor.java | 5 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 2 +-
.../consensus/request/auth/AuthorPlan.java | 2 +-
.../subscription/SubscriptionTableResp.java | 4 +-
.../statemachine/ConfigRegionStateMachine.java | 32 +-
.../iotdb/confignode/manager/ConfigManager.java | 6 +-
.../manager/consensus/ConsensusManager.java | 3 +-
.../manager/load/balancer/RegionBalancer.java | 9 +-
.../manager/load/balancer/RouteBalancer.java | 3 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 100 +++-
.../region/GreedyRegionGroupAllocator.java | 40 +-
.../balancer/region/IRegionGroupAllocator.java | 3 +
.../router/leader/GreedyLeaderBalancer.java | 129 +----
.../balancer/router/leader/ILeaderBalancer.java | 6 +-
.../router/leader/MinCostFlowLeaderBalancer.java | 211 +++++---
.../iotdb/confignode/manager/node/NodeManager.java | 7 +
.../manager/partition/PartitionManager.java | 24 +
.../{transfer => }/agent/PipeConfigNodeAgent.java | 10 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 2 +-
.../PipeConfigRegionConnectorConstructor.java | 6 +-
.../PipeConfigRegionExtractorConstructor.java | 4 +-
.../PipeConfigRegionProcessorConstructor.java | 2 +-
.../receiver/IoTDBConfigNodeReceiverAgent.java | 26 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 12 +-
.../agent/runtime/PipeConfigRegionListener.java | 6 +-
.../agent/task/PipeConfigNodeTaskAgent.java | 15 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../PipeTransferConfigNodeHandshakeV1Req.java | 2 +-
.../PipeTransferConfigNodeHandshakeV2Req.java | 2 +-
.../payload}/PipeTransferConfigPlanReq.java | 2 +-
.../PipeTransferConfigSnapshotPieceReq.java | 2 +-
.../payload/PipeTransferConfigSnapshotSealReq.java | 113 +++++
.../protocol/IoTDBConfigRegionAirGapConnector.java | 186 +++++++
.../protocol}/IoTDBConfigRegionConnector.java | 143 +++---
.../runtime/PipeHeartbeatScheduler.java | 2 +-
.../runtime/PipeLeaderChangeHandler.java | 23 +-
.../runtime/PipeRuntimeCoordinator.java | 6 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 4 -
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 189 ++++++-
.../execution/PipeConfigNodeSubtask.java | 14 +-
.../execution/PipeConfigNodeSubtaskExecutor.java | 2 +-
.../extractor/ConfigRegionListeningFilter.java | 4 +-
.../extractor/ConfigRegionListeningQueue.java | 42 +-
.../extractor/IoTDBConfigRegionExtractor.java | 51 +-
.../protocol}/IoTDBConfigNodeReceiver.java | 132 ++++-
.../PipeConfigPhysicalPlanExceptionVisitor.java | 2 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 11 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 52 ++
.../{transfer => }/task/PipeConfigNodeTask.java | 2 +-
.../task/PipeConfigNodeTaskBuilder.java | 11 +-
.../task/PipeConfigNodeTaskStage.java | 10 +-
.../config/IoTDBConfigRegionAirGapConnector.java | 160 ------
.../request/PipeTransferConfigSnapshotSealReq.java | 70 ---
.../manager/schema/ClusterSchemaManager.java | 2 +-
.../subscription/SubscriptionCoordinator.java | 5 +
.../iotdb/confignode/persistence/AuthorInfo.java | 4 +-
.../confignode/persistence/ProcedureInfo.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 9 +-
.../persistence/partition/PartitionInfo.java | 47 +-
.../confignode/persistence/pipe/PipeInfo.java | 2 +-
.../schema/CNPhysicalPlanGenerator.java | 81 ++-
.../persistence/schema/CNSnapshotFileType.java | 35 +-
.../schema/ConfignodeSnapshotParser.java | 32 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../persistence/subscription/SubscriptionInfo.java | 2 +-
.../impl/region/AddRegionPeerProcedure.java | 4 +
.../impl/region/RegionMigrateProcedure.java | 2 +
.../impl/region/RemoveRegionPeerProcedure.java | 4 +
.../AbstractOperateSubscriptionProcedure.java | 13 +-
.../consumer/AlterConsumerGroupProcedure.java | 2 +-
.../runtime/ConsumerGroupMetaSyncProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 2 +-
.../subscription/topic/AlterTopicProcedure.java | 2 +-
.../subscription/topic/CreateTopicProcedure.java | 2 +-
.../subscription/topic/DropTopicProcedure.java | 2 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 11 +-
.../region/AllocatorScatterWidthManualTest.java | 5 +
.../GreedyCopySetRegionGroupAllocatorTest.java | 115 +++--
.../region/GreedyRegionGroupAllocatorTest.java | 4 +
...alancerTest.java => CFDLeaderBalancerTest.java} | 66 +--
.../router/leader/GreedyLeaderBalancerTest.java | 6 +-
.../leader/LeaderBalancerComparisonTest.java | 4 +-
.../connector/IoTDBConfigRegionConnectorTest.java | 2 +-
.../PipeConfigNodeThriftRequestTest.java | 25 +-
.../PipeConfigNodeSubtaskExecutorTest.java | 2 -
.../extractor/IoTDBConfigRegionExtractorTest.java | 1 -
.../persistence/CNPhysicalPlanGeneratorTest.java | 142 +++---
.../confignode/persistence/ClusterInfoTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../confignode/persistence/ProcedureInfoTest.java | 2 +-
.../UpgradeFromWALToConsensusLayerTest.java | 6 +-
.../org/apache/iotdb/consensus/IConsensus.java | 6 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 60 ++-
.../consensus/iot/IoTConsensusServerImpl.java | 69 ++-
.../service/IoTConsensusRPCServiceProcessor.java | 5 +
.../iotdb/consensus/natraft/RaftConsensus.java | 2 +-
.../consensus/natraft/protocol/RaftMember.java | 2 +-
.../protocol/log/snapshot/DirectorySnapshot.java | 2 +-
.../apache/iotdb/consensus/ratis/DiskGuardian.java | 17 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 4 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 8 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 2 +-
.../iotdb/consensus/nbraft/RaftConsensusTest.java | 6 +-
.../iotdb/consensus/nbraft/RecoverReadTest.java | 3 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 12 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 25 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 26 +-
.../dataregion/DataExecutionVisitor.java | 11 +-
.../schemaregion/SchemaRegionStateMachine.java | 47 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 27 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 10 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 3 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 1 +
.../request/PipeTransferSchemaSnapshotSealReq.java | 52 +-
.../PipeTransferTsFilePieceWithModReq.java} | 24 +-
.../request/PipeTransferTsFileSealReq.java | 4 +-
....java => PipeTransferTsFileSealWithModReq.java} | 40 +-
.../connector/payload/legacy/DeletionPipeData.java | 4 +-
.../db/pipe/connector/payload/legacy/PipeData.java | 2 +-
.../connector/payload/legacy/TsFilePipeData.java | 4 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 16 +-
.../airgap/IoTDBDataRegionAirGapConnector.java | 122 +++--
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 111 +++--
.../connector/protocol/opcua/OpcUaConnector.java | 8 +-
.../async/IoTDBDataRegionAsyncConnector.java | 4 +
.../PipeTransferTabletBatchEventHandler.java | 13 +-
.../PipeTransferTabletInsertionEventHandler.java | 11 +-
.../PipeTransferTsFileInsertionEventHandler.java | 82 ++-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 17 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 172 +++----
.../thrift/sync/IoTDBSchemaRegionConnector.java | 113 ++---
.../schema/PipeSchemaRegionSnapshotEvent.java | 157 +++++-
.../common/tsfile/PipeTsFileInsertionEvent.java | 60 ++-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../PipeConnectorSubtaskExecutor.java | 2 +-
.../PipeProcessorSubtaskExecutor.java | 2 +-
.../{executor => }/PipeSubtaskExecutorManager.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 32 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 55 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 31 +-
.../PipeRealtimeDataRegionLogExtractor.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 11 +-
.../realtime/epoch/TsFileEpochManager.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 4 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 58 ++-
.../schemaregion/SchemaRegionListeningFilter.java | 6 +-
.../schemaregion/SchemaRegionListeningQueue.java | 18 +-
.../{matcher => }/CachedSchemaPatternMatcher.java | 2 +-
.../{matcher => }/PipeDataRegionMatcher.java | 2 +-
.../processor/aggregate/AggregateProcessor.java | 8 +-
.../window/datastructure/TimeSeriesWindow.java | 3 -
.../SimpleConsensusProgressIndexAssigner.java | 2 +-
.../{ => protocol}/airgap/IoTDBAirGapReceiver.java | 16 +-
.../airgap/IoTDBAirGapReceiverAgent.java | 2 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +-
.../legacy/loader/DeletionLoader.java | 2 +-
.../{ => protocol}/legacy/loader/ILoader.java | 2 +-
.../{ => protocol}/legacy/loader/TsFileLoader.java | 2 +-
.../thrift/IoTDBDataNodeReceiver.java | 127 ++---
.../thrift/IoTDBDataNodeReceiverAgent.java | 2 +-
.../{ => visitor}/PipePlanToStatementVisitor.java | 7 +-
.../PipeStatementExceptionVisitor.java | 29 +-
.../PipeStatementTSStatusVisitor.java | 8 +-
...NodeHardlinkOrCopiedFileDirStartupCleaner.java} | 26 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 70 +--
.../db/pipe/task/builder/PipeDataNodeBuilder.java | 28 +-
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 6 +-
.../pipe/task/connection/PipeEventCollector.java | 2 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 2 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 2 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../connector/PipeConnectorSubtaskManager.java | 4 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 6 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 31 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../db/queryengine/execution/driver/Driver.java | 2 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../execution/load/LoadTsFileManager.java | 2 +-
.../schema/source/TimeSeriesSchemaSource.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 11 +-
.../analyze/cache/partition/PartitionCache.java | 12 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 6 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../plan/optimization/LimitOffsetPushDown.java | 48 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 59 +--
.../plan/planner/plan/node/PlanNodeType.java | 4 +-
.../node/metedata/write/DeleteTimeSeriesNode.java | 6 +-
.../write/InternalCreateTimeSeriesNode.java | 6 +-
.../queryengine/plan/statement/StatementType.java | 12 +-
.../metadata/AlterTimeSeriesStatement.java | 4 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 8 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 2 +-
.../rescon/DataNodeSchemaQuotaManager.java | 30 +-
.../rescon/ISchemaRegionStatistics.java | 2 +-
.../rescon/MemSchemaEngineStatistics.java | 29 +-
.../rescon/MemSchemaRegionStatistics.java | 40 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 25 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 42 +-
.../schemaregion/mtree/traverser/Traverser.java | 13 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 68 ++-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 14 +-
.../db/storageengine/dataregion/DataRegion.java | 86 ++--
.../compaction/repair/RepairDataFileScanUtil.java | 6 +-
.../DefaultCompactionTaskComparatorImpl.java | 21 +-
.../dataregion/read/control/FileReaderManager.java | 4 +-
.../dataregion/snapshot/SnapshotTaker.java | 2 +-
.../wal/allocation/FirstCreateStrategy.java | 2 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 2 +-
.../quotas/DataNodeThrottleQuotaManager.java | 14 +-
.../agent/SubscriptionAgentLauncher.java | 2 +-
.../agent/SubscriptionBrokerAgent.java | 12 +-
.../agent/SubscriptionConsumerAgent.java | 4 +-
.../agent/SubscriptionRuntimeAgent.java | 7 -
.../broker/SerializedEnrichedEvent.java | 26 +-
.../db/subscription/broker/SubscriptionBroker.java | 47 +-
.../broker/SubscriptionPrefetchingQueue.java | 99 ++--
.../executor/SubscriptionSubtaskExecutor.java | 2 +-
.../receiver/SubscriptionReceiverV1.java | 110 ++--
.../task/stage/SubscriptionTaskConnectorStage.java | 2 +-
.../SubscriptionConnectorSubtaskLifeCycle.java | 2 +-
.../SubscriptionConnectorSubtaskManager.java | 6 +-
.../subscription/timer/SubscriptionPollTimer.java | 79 +++
.../db/tools/schema/SRStatementGenerator.java | 51 +-
.../tools/schema/SchemaRegionSnapshotParser.java | 67 +--
.../schemaRegion/SchemaStatisticsTest.java | 12 +-
.../connector/PipeDataNodeThriftRequestTest.java | 36 +-
.../iotdb/db/pipe/connector/PipeReceiverTest.java | 2 +-
.../PipeConnectorSubtaskExecutorTest.java | 1 -
.../PipeProcessorSubtaskExecutorTest.java | 1 -
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 2 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 1 -
.../PipeDataNodeSnapshotResourceManagerTest.java | 25 +-
.../resource/PipeTsFileResourceManagerTest.java | 2 +-
.../PipeWALHardlinkResourceManagerTest.java | 2 +-
.../dataregion/compaction/TsFileIdentifierUT.java | 2 +-
.../repair/RepairDataFileScanUtilTest.java | 29 ++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 10 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 2 +-
.../apache/iotdb/db/utils/sort/SortUtilTest.java | 2 +-
.../apache/iotdb/metrics/utils/SystemMetric.java | 2 +-
.../resources/conf/iotdb-common.properties | 9 -
.../commons/auth/role/LocalFileRoleAccessor.java | 6 +-
.../commons/auth/user/LocalFileUserAccessor.java | 8 +-
.../sync/SyncThriftClientWithErrorHandler.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 60 ++-
.../iotdb/commons/conf/CommonDescriptor.java | 22 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 5 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 2 +-
.../{ => subscription}/SubscriptionException.java | 2 +-
.../SubscriptionPollTimeOutException.java | 14 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 5 +-
.../config/constant/PipeExtractorConstant.java | 5 +
.../pipe/connector/PipeReceiverStatusHandler.java | 52 +-
.../pipe/connector/client/IoTDBClientManager.java | 8 +
.../pipe/connector/client/IoTDBSyncClient.java | 13 +
.../connector/client/IoTDBSyncClientManager.java | 36 +-
.../payload/thrift/request/PipeRequestType.java | 10 +-
...SealReq.java => PipeTransferFileSealReqV1.java} | 8 +-
.../thrift/request/PipeTransferFileSealReqV2.java | 165 ++++++
.../connector/protocol/IoTDBAirGapConnector.java | 92 +++-
.../connector/protocol/IoTDBSslSyncConnector.java | 82 +++
.../options/PipeInclusionOptions.java | 19 +-
.../listening/AbstractPipeListeningQueue.java | 78 +--
.../iotdb/commons/pipe/event/EnrichedEvent.java | 2 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 69 +--
.../commons/pipe/extractor/IoTDBExtractor.java | 2 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 62 ++-
.../pipe/metric/PipeEventCommitMetrics.java | 2 +-
.../connector/donothing/DoNothingConnector.java | 16 +-
.../{committer => }/PipeEventCommitManager.java | 2 +-
.../{committer => }/PipeEventCommitter.java | 2 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 285 ++++++++---
.../iotdb/commons/pipe/receiver/IoTDBReceiver.java | 2 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 25 +-
.../pipe/resource/PipeSnapshotResourceManager.java | 62 +--
.../commons/pipe/task/stage/PipeTaskStage.java | 4 +-
.../service/AbstractThriftServiceThread.java | 4 +-
.../subscription/config/SubscriptionConfig.java | 26 +-
.../meta/consumer/ConsumerGroupMeta.java | 2 +-
.../subscription/meta/consumer/ConsumerMeta.java | 2 +-
.../meta/subscription/SubscriptionMeta.java | 44 +-
.../commons/subscription/meta/topic/TopicMeta.java | 6 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 65 ++-
.../utils/KillPoint/DataNodeKillPoints.java | 22 +-
.../IoTConsensusRemovePeerKillPoints.java} | 13 +-
.../iotdb/commons/utils/KillPoint/KillPoint.java | 80 +++
.../NeverTriggeredKillPoint.java} | 10 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 1 +
.../consumer/ConsumerGroupDeSerTest.java | 2 +-
.../org/apache/iotdb/tsfile/compress/LZ4Test.java | 21 +
.../src/main/thrift/confignode.thrift | 1 +
pom.xml | 1 -
407 files changed, 10721 insertions(+), 5000 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2.java
=> MultiClusterIT2AutoCreateSchema.java} (94%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2.java
=> MultiClusterIT2ManualCreateSchema.java} (94%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2.java
=> MultiClusterIT2Subscription.java} (94%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/load/IoTDBMultiDBRegionGroupLeaderDistributionIT.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/load/{IoTDBClusterRegionLeaderBalancingIT.java
=> IoTDBRegionGroupLeaderDistributionIT.java} (74%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBRegionMigrateReliabilityIT.java
=> regionmigration/IoTDBRegionMigrateReliabilityITFramework.java} (50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/notpass/datanodecrash/CoordinatorRemoveRemotePeerCrashIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/notpass/datanodecrash/IoTDBRegionMigrateDataNodeCrashIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/IoTDBRegionMigrateConfigNodeCrashIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/task/PipeConfigNodeTask.java
=>
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/IoTDBRegionMigrateNormalIT.java
(52%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/IoTDBRegionMigrateOtherIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeMetaHistoricalIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionBasicIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionConsumerGroupIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionTopicIT.java
copy
integration-test/src/test/java/org/apache/iotdb/{pipe/it/autocreate/AbstractPipeDualAutoIT.java
=> subscription/it/dual/AbstractSubscriptionDualIT.java} (94%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionConsumerGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTopicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionIdempotentIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionRestartIT.java
rename
integration-test/src/test/java/org/apache/iotdb/tools/it/{ExportCsvTestIT.java
=> ExportDataTestIT.java} (77%)
rename
integration-test/src/test/java/org/apache/iotdb/tools/it/{ImportCsvTestIT.java
=> ImportDataTestIT.java} (94%)
rename iotdb-client/cli/src/assembly/resources/tools/{export-csv.bat =>
export-data.bat} (99%)
rename iotdb-client/cli/src/assembly/resources/tools/{export-csv.sh =>
export-data.sh} (97%)
rename iotdb-client/cli/src/assembly/resources/tools/{import-csv.bat =>
import-data.bat} (99%)
rename iotdb-client/cli/src/assembly/resources/tools/{import-csv.sh =>
import-data.sh} (97%)
rename
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{AbstractCsvTool.java =>
AbstractDataTool.java} (98%)
rename iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{ExportCsv.java =>
ExportData.java} (69%)
rename iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{ImportCsv.java =>
ImportData.java} (94%)
rename
iotdb-client/cli/src/test/java/org/apache/iotdb/tool/{WriteCsvFileTest.java =>
WriteDataFileTest.java} (87%)
copy
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/EnrichedRowRecord.java
=> isession/src/main/java/org/apache/iotdb/isession/ISessionDataSet.java} (76%)
copy {iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription}/SubscriptionException.java
(72%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/{payload
=> }/config/ConsumerConfig.java (97%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/{payload
=> }/config/ConsumerConstant.java (55%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/{payload
=> }/config/TopicConfig.java (98%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/{payload
=> }/config/TopicConstant.java (95%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/{response
=> }/EnrichedTablets.java (94%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ConsumerHeartbeatWorker.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/PullConsumerAutoCommitWorker.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionMessage.java
rename
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionMessagePayload.java
(87%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionProvider.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionPullConsumer.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/task/PipeConfigNodeTask.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionPushConsumer.java
(55%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionConnection.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionDataSet.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionDataSets.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/task/PipeConfigNodeTask.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/model/Subscription.java
(52%)
rename
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/EnrichedRowRecord.java
=>
session/src/main/java/org/apache/iotdb/session/subscription/model/Topic.java}
(62%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/PipeConfigNodeAgent.java (86%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/plugin/PipeConfigNodePluginAgent.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/plugin/PipeConfigRegionConnectorConstructor.java (91%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/plugin/PipeConfigRegionExtractorConstructor.java (92%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/plugin/PipeConfigRegionProcessorConstructor.java (95%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/receiver/IoTDBConfigNodeReceiverAgent.java (62%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/runtime/PipeConfigNodeRuntimeAgent.java (90%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/runtime/PipeConfigRegionListener.java (90%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/agent/task/PipeConfigNodeTaskAgent.java (94%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/connector/client/IoTDBConfigNodeSyncClientManager.java (86%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/connector/payload/request
=> connector/payload}/PipeTransferConfigNodeHandshakeV1Req.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/connector/payload/request
=> connector/payload}/PipeTransferConfigNodeHandshakeV2Req.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/connector/payload/request
=> connector/payload}/PipeTransferConfigPlanReq.java (97%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/connector/payload/request
=> connector/payload}/PipeTransferConfigSnapshotPieceReq.java (96%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/payload/PipeTransferConfigSnapshotSealReq.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/protocol/IoTDBConfigRegionAirGapConnector.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/connector/config
=> connector/protocol}/IoTDBConfigRegionConnector.java (58%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/execution/PipeConfigNodeSubtask.java (95%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/execution/PipeConfigNodeSubtaskExecutor.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/extractor/ConfigRegionListeningFilter.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/extractor/ConfigRegionListeningQueue.java (74%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/extractor/IoTDBConfigRegionExtractor.java (52%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/agent/receiver
=> receiver/protocol}/IoTDBConfigNodeReceiver.java (62%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/agent/receiver
=> receiver/visitor}/PipeConfigPhysicalPlanExceptionVisitor.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer/agent/receiver
=> receiver/visitor}/PipeConfigPhysicalPlanTSStatusVisitor.java (97%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/PipeConfigNodeCopiedFileDirStartupCleaner.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/task/PipeConfigNodeTask.java (95%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/task/PipeConfigNodeTaskBuilder.java (85%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{transfer
=> }/task/PipeConfigNodeTaskStage.java (87%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/connector/config/IoTDBConfigRegionAirGapConnector.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/connector/payload/request/PipeTransferConfigSnapshotSealReq.java
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/{MinCostFlowLeaderBalancerTest.java
=> CFDLeaderBalancerTest.java} (78%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{
=> connector}/PipeConfigNodeThriftRequestTest.java (76%)
rename
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/connector/payload/request/PipeTransferConfigSnapshotPieceReq.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferTsFilePieceWithModReq.java}
(71%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferTsFileSealReq.java
=> PipeTransferTsFileSealWithModReq.java} (53%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/{executor
=> }/PipeConnectorSubtaskExecutor.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/{executor
=> }/PipeProcessorSubtaskExecutor.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/{executor
=> }/PipeSubtaskExecutorManager.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/pattern/{matcher =>
}/CachedSchemaPatternMatcher.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/pattern/{matcher =>
}/PipeDataRegionMatcher.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/progress/{assigner
=> }/SimpleConsensusProgressIndexAssigner.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/airgap/IoTDBAirGapReceiver.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/airgap/IoTDBAirGapReceiverAgent.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/legacy/IoTDBLegacyPipeReceiverAgent.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/legacy/loader/DeletionLoader.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/legacy/loader/ILoader.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/legacy/loader/TsFileLoader.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/thrift/IoTDBDataNodeReceiver.java (77%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> protocol}/thrift/IoTDBDataNodeReceiverAgent.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> visitor}/PipePlanToStatementVisitor.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> visitor}/PipeStatementExceptionVisitor.java (73%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/{
=> visitor}/PipeStatementTSStatusVisitor.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/{PipeHardlinkFileDirStartupCleaner.java
=> PipeDataNodeHardlinkOrCopiedFileDirStartupCleaner.java} (66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/timer/SubscriptionPollTimer.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{ =>
subscription}/SubscriptionException.java (96%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/config/ConsumerConstant.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/subscription/SubscriptionPollTimeOutException.java
(71%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/thrift/request/{PipeTransferFileSealReq.java
=> PipeTransferFileSealReqV1.java} (91%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/thrift/request/PipeTransferFileSealReqV2.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/progress/{committer
=> }/PipeEventCommitManager.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/progress/{committer
=> }/PipeEventCommitter.java (98%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/IoTDBSubscriptionDataSet.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/KillPoint/DataNodeKillPoints.java
(74%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/{DataNodeKillPoints.java
=> KillPoint/IoTConsensusRemovePeerKillPoints.java} (81%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/KillPoint/KillPoint.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/{DataNodeKillPoints.java
=> KillPoint/NeverTriggeredKillPoint.java} (83%)
