This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9a67740018a [IoTV2] Add ConfigNode-side consensus pipe guardian and
remove deprecated DataNode-side checking (#17277)
add ccece97de76 rename pipe consensus to iot consensus v2 (#17291)
No new revisions were added by this update.
Summary of changes:
.github/workflows/daily-it.yml | 60 +--
integration-test/pom.xml | 56 +--
.../iotdb/it/env/cluster/ClusterConstant.java | 60 +--
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 24 +-
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 50 ++-
.../it/env/remote/config/RemoteCommonConfig.java | 2 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 16 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 8 +-
.../procedure/env/RegionMaintainHandler.java | 4 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 9 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
...sensusConfig.java => IoTConsensusV2Config.java} | 12 +-
.../{PipeConsensus.java => IoTConsensusV2.java} | 64 +--
...Manager.java => IoTConsensusV2PeerManager.java} | 6 +-
...rverImpl.java => IoTConsensusV2ServerImpl.java} | 74 ++--
.../pipe/consensuspipe/ConsensusPipeReceiver.java | 6 +-
...trics.java => IoTConsensusV2ServerMetrics.java} | 38 +-
...ager.java => IoTConsensusV2SyncLagManager.java} | 24 +-
...CService.java => IoTConsensusV2RPCService.java} | 35 +-
...r.java => IoTConsensusV2RPCServiceHandler.java} | 6 +-
...ean.java => IoTConsensusV2RPCServiceMBean.java} | 2 +-
...java => IoTConsensusV2RPCServiceProcessor.java} | 68 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../db/consensus/DataRegionConsensusImpl.java | 21 +-
.../PipeDataRegionProcessorConstructor.java | 6 +-
.../dataregion/PipeDataRegionSinkConstructor.java | 10 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 14 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 4 +-
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../task/execution/PipeSubtaskExecutorManager.java | 8 +-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
...tor.java => IoTConsensusV2SubtaskExecutor.java} | 6 +-
.../ReplicateProgressDataNodeManager.java | 8 +-
.../pipe/consensus/deletion/DeletionResource.java | 2 +-
.../deletion/DeletionResourceManager.java | 12 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 4 +-
...ics.java => IoTConsensusV2ReceiverMetrics.java} | 76 ++--
...Metrics.java => IoTConsensusV2SinkMetrics.java} | 60 +--
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 16 +-
.../IoTConsensusV2Processor.java} | 6 +-
.../IoTConsensusV2Receiver.java} | 482 +++++++++++----------
.../IoTConsensusV2ReceiverAgent.java} | 87 ++--
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 8 +-
.../IoTConsensusV2AsyncSink.java} | 222 +++++-----
.../IoTConsensusV2SyncSink.java} | 156 +++----
.../handler/IoTConsensusV2DeleteEventHandler.java} | 42 +-
.../IoTConsensusV2TabletBatchEventHandler.java} | 56 +--
...oTConsensusV2TabletInsertNodeEventHandler.java} | 28 +-
...IoTConsensusV2TabletInsertionEventHandler.java} | 39 +-
...IoTConsensusV2TsFileInsertionEventHandler.java} | 79 ++--
.../IoTConsensusV2AsyncBatchReqBuilder.java} | 6 +-
.../IoTConsensusV2SyncBatchReqBuilder.java} | 8 +-
.../IoTConsensusV2TransferBatchReqBuilder.java} | 34 +-
.../request/IoTConsensusV2DeleteNodeReq.java} | 32 +-
.../request/IoTConsensusV2TabletBatchReq.java} | 37 +-
.../request/IoTConsensusV2TabletBinaryReq.java} | 32 +-
.../IoTConsensusV2TabletInsertNodeReq.java} | 36 +-
.../request/IoTConsensusV2TsFilePieceReq.java} | 36 +-
.../IoTConsensusV2TsFilePieceWithModReq.java} | 38 +-
.../request/IoTConsensusV2TsFileSealReq.java} | 36 +-
.../IoTConsensusV2TsFileSealWithModReq.java} | 36 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 10 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 8 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../compaction/execute/utils/CompactionUtils.java | 14 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 18 +-
.../db/storageengine/load/LoadTsFileManager.java | 4 +-
.../PipeDataNodeSnapshotResourceManagerTest.java | 12 +-
.../iotdb/commons/client/ClientPoolFactory.java | 44 +-
....java => AsyncIoTConsensusV2ServiceClient.java} | 24 +-
...erty.java => IoTConsensusV2ClientProperty.java} | 22 +-
...t.java => SyncIoTConsensusV2ServiceClient.java} | 26 +-
.../iotdb/commons/concurrent/ThreadName.java | 32 +-
.../container/IoTV2GlobalComponentContainer.java | 40 +-
...susV2RetryWithIncreasingIntervalException.java} | 4 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 17 +-
.../IoTConsensusV2Processor.java} | 8 +-
...AsyncSink.java => IoTConsensusV2AsyncSink.java} | 6 +-
.../agent/task/subtask/PipeReportableSubtask.java | 4 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 4 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 4 +-
.../request/IoTConsensusV2RequestType.java} | 20 +-
.../request/IoTConsensusV2RequestVersion.java} | 6 +-
.../IoTConsensusV2TransferFilePieceReq.java} | 20 +-
.../IoTConsensusV2TransferFileSealReq.java} | 22 +-
.../IoTConsensusV2TransferFileSealWithModReq.java} | 20 +-
.../IoTConsensusV2TransferFilePieceResp.java} | 30 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/service/metric/enums/Metric.java | 4 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 6 +-
...{pipeconsensus.thrift => iotconsensusv2.thrift} | 24 +-
100 files changed, 1473 insertions(+), 1457 deletions(-)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/{PipeConsensusConfig.java
=> IoTConsensusV2Config.java} (96%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/{PipeConsensus.java
=> IoTConsensusV2.java} (89%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/{PipeConsensusPeerManager.java
=> IoTConsensusV2PeerManager.java} (90%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/{PipeConsensusServerImpl.java
=> IoTConsensusV2ServerImpl.java} (87%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/{PipeConsensusServerMetrics.java
=> IoTConsensusV2ServerMetrics.java} (84%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/{PipeConsensusSyncLagManager.java
=> IoTConsensusV2SyncLagManager.java} (85%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCService.java
=> IoTConsensusV2RPCService.java} (70%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCServiceHandler.java
=> IoTConsensusV2RPCServiceHandler.java} (86%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCServiceMBean.java
=> IoTConsensusV2RPCServiceMBean.java} (94%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCServiceProcessor.java
=> IoTConsensusV2RPCServiceProcessor.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/{PipeConsensusSubtaskExecutor.java
=> IoTConsensusV2SubtaskExecutor.java} (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/{PipeConsensusReceiverMetrics.java
=> IoTConsensusV2ReceiverMetrics.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/{PipeConsensusSinkMetrics.java
=> IoTConsensusV2SinkMetrics.java} (82%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/{pipeconsensus/PipeConsensusProcessor.java
=> iotconsensusv2/IoTConsensusV2Processor.java} (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/{pipeconsensus/PipeConsensusReceiver.java
=> iotconsensusv2/IoTConsensusV2Receiver.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/{pipeconsensus/PipeConsensusReceiverAgent.java
=> iotconsensusv2/IoTConsensusV2ReceiverAgent.java} (72%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/PipeConsensusAsyncSink.java
=> iotconsensusv2/IoTConsensusV2AsyncSink.java} (71%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/PipeConsensusSyncSink.java
=> iotconsensusv2/IoTConsensusV2SyncSink.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusDeleteEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2DeleteEventHandler.java} (71%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTabletBatchEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TabletBatchEventHandler.java} (61%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTabletInsertNodeEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TabletInsertNodeEventHandler.java}
(53%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTabletInsertionEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TabletInsertionEventHandler.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTsFileInsertionEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TsFileInsertionEventHandler.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/builder/PipeConsensusAsyncBatchReqBuilder.java
=> iotconsensusv2/payload/builder/IoTConsensusV2AsyncBatchReqBuilder.java}
(85%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/builder/PipeConsensusSyncBatchReqBuilder.java
=> iotconsensusv2/payload/builder/IoTConsensusV2SyncBatchReqBuilder.java} (81%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/builder/PipeConsensusTransferBatchReqBuilder.java
=> iotconsensusv2/payload/builder/IoTConsensusV2TransferBatchReqBuilder.java}
(85%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2DeleteNodeReq.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTabletBatchReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TabletBatchReq.java} (54%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTabletBinaryReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TabletBinaryReq.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTabletInsertNodeReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TabletInsertNodeReq.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFilePieceReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFilePieceReq.java} (57%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFilePieceWithModReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFilePieceWithModReq.java}
(55%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFileSealReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFileSealReq.java} (59%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFileSealWithModReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFileSealWithModReq.java}
(60%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/async/{AsyncPipeConsensusServiceClient.java
=> AsyncIoTConsensusV2ServiceClient.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/property/{PipeConsensusClientProperty.java
=> IoTConsensusV2ClientProperty.java} (81%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/{SyncPipeConsensusServiceClient.java
=> SyncIoTConsensusV2ServiceClient.java} (82%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/{PipeConsensusRetryWithIncreasingIntervalException.java
=> IoTConsensusV2RetryWithIncreasingIntervalException.java} (85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/{pipeconsensus/PipeConsensusProcessor.java
=> iotconsensusv2/IoTConsensusV2Processor.java} (82%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/sink/iotdb/consensus/{PipeConsensusAsyncSink.java
=> IoTConsensusV2AsyncSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusRequestType.java
=> iotconsensusv2/request/IoTConsensusV2RequestType.java} (70%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusRequestVersion.java
=> iotconsensusv2/request/IoTConsensusV2RequestVersion.java} (85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusTransferFilePieceReq.java
=> iotconsensusv2/request/IoTConsensusV2TransferFilePieceReq.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusTransferFileSealReq.java
=> iotconsensusv2/request/IoTConsensusV2TransferFileSealReq.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusTransferFileSealWithModReq.java
=> iotconsensusv2/request/IoTConsensusV2TransferFileSealWithModReq.java} (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/response/PipeConsensusTransferFilePieceResp.java
=> iotconsensusv2/response/IoTConsensusV2TransferFilePieceResp.java} (71%)
rename iotdb-protocol/thrift-consensus/src/main/thrift/{pipeconsensus.thrift
=> iotconsensusv2.thrift} (81%)
