This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch batch_wal
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from aea11d24c13 fix redo insert rows bug
add 360254be7c7 Fix recover duplicate (#12272)
add b64cf1c7119 Fix mismatched dataType with same name
add d6c9bbc88c8 Subscription: refactor `IoTDBSubscriptionConsumerGroupIT`
to support multi-protocol pipe sync reference (#12288)
add d17d0ef7d92 Pipe: Fix websocket (Flink CDC) connector may report
tsfile event progress in advance (#12284)
add f5213bfb49c Optimize time cost on rewrite pattern by authority pattern
add 8f1242593b4 Fix stop datanode compaction error log (#12178)
add 943eacab300 Pipe & Subscription IT: Enlarge -DDataNodeMaxHeapSize &
-DDataNodeMaxDirectMemorySize. Add StrongConsistencyClusterMode for receiver
tests. (#12289)
add 011e4011d16 Pipe IT: remove StrongConsistencyClusterMode tests from
manual-create-schema IT (#12292)
add 5394aa47fa9 Use UTF-8 to load and store properties file (#12291)
add 90cc430f6f1 Pipe: Added parameters to the snapshot transfer threshold
from last snapshot to queue's tail index (#12290)
add 347e42d59c7 Pipe: Improved the air gap receiver socket close handling
logic (#12285)
add cff2ff15304 Pipe: Fixed the NPE when an emit is triggered by a generic
event in aggregate processor (#12298)
add e8d11ce91b8 Pipe IT: Configured the connection timeout ms parameter to
avoid premature timeout of pipe creation in ITs (#12295)
add 0492b6a9a83 Pipe: Fix receiver can not delete dir on thread exit if
files in dir are not loaded successfully (#12302)
add 917fd4e9b0c Pipe: Added output.measurements and output.database format
check in AggregateProcessor (#12300)
add 688d5e02f3c docs: proofread the readme file (#12296)
add 08b3772a798 Pipe: check metric service before marking pipe metrics to
avoid useless warn logs (#12303)
add eee72fbf3aa [IOTDB-6301] wait leader ready in single replica (#12234)
add e1066549218 fix delete dead lock.
add cbc7ba56b19 Load: support load tsfile with data in partition whose id
is negative (#12307)
add 75b5fa607b4 Subscription: intro node-urls and endpoints syncer for
consumer high availablity (#12275)
add dddedf06260 Fix potential NPE when concurrently aborting a Query
add 40993a2b5b8 Pipe: decrease reference count for untransferred events in
batch when closing & fix parsing alter pipe name (#12305)
add ecdb0566d8d Storage Engine: Fixed inaccurate compression ratio when
writing duplicate data (#12297)
add 80ff23ff5d7 Pipe: Fixed the bug that config receivers may not be
one-to-one match with the sender clients (#12280)
add 503776b3c88 delay estimate memory of InnerSpaceCompactionTask (#12314)
add 78315b3fb45 Pipe: Added get-jar-with-dependencies packaging option for
pipe-opc-ua-sink-example (#12317)
add a4d60b2ae97 Bump tar from 6.1.13 to 6.2.1 in
/iotdb-connector/grafana-plugin (#12319)
add 1c83bc0d5a3 Do not set read only in compaction module (#12311)
add d28417bac6d Subscription: fix parsing topic name with back quote when
using JAVA SDK client (#12322)
add 381948b52f5 Bump org.apache.zeppelin:zeppelin-interpreter from 0.10.1
to 0.11.1 (#12324)
add 3f3b4f78185 feature add health_check (#12325)
add f52d752bf84 Region migration related work (#12293)
add 199342da8df Pipe: clear event reference count instead of decreasing
when closing to improve idempotence & add creation time for committer key to
avoid outdated commit & detect re-increasing reference count to avoid NPE
(#12315)
add 9c9a70e14cd Implement DataNodeSchemaLockManager for distributed
concurrency control
add 44b263e2a93 Fix bug change the hasnext impl of session data set
add 214c49a2108 new iot_consensus_throttle_threshold_in_byte (#12333)
add f4804a41440 Thread-safety load balance infrastructure (#12330)
add 13560ee1eab [RatisConsensus] Bump Ratis snapshot version to 8eafc4f
(#12335)
add 3d5f7017f8f Pipe: Reset the inclusion settings to data.insert (#12337)
add 9b5361c1742 Pipe: AggregateProcessor: Fixed the bug that processor may
not change the database prefix when output is from another database's
processor's input & Fixed heartbeat output not pipe local and non-atomic bug &
Fixed new processor wipe out states bug (#12338)
add 89ebd32b1be Add Linux Memory Metrics (#12332)
add 6e4863bfb51 Fix auto leader balance for Ratis protocol judgement bug
(#12350)
add bb7d29f1a09 Print progress in log during transmitting snapshot for
region migration (#12346)
add 56d4c9b8ddb Update Link of IoTDB Introduction.md (#12323)
add b93d4105d1c Update README_ZH.md (#12352)
add 339783de987 Merge branch 'master' of github.com:apache/iotdb into
batch_wal
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 8 +-
README.md | 65 +-
README_ZH.md | 1 +
example/pipe-opc-ua-sink/pom.xml | 34 +
.../apache/iotdb/SubscriptionSessionExample.java | 18 +-
.../iotdb/it/env/cluster/config/MppBaseConfig.java | 4 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 29 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 5 +
.../env/remote/config/RemoteConfigNodeConfig.java | 6 +
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
...IoTDBRegionMigrateDataNodeCrashITFramework.java | 15 +-
.../IoTDBRegionMigrateReliabilityITFramework.java | 412 +++++++++---
.../it/regionmigration/KillPointContext.java | 25 +-
.../pass/IoTDBRegionMigrateClusterCrashIT.java | 68 ++
.../pass/IoTDBRegionMigrateConfigNodeCrashIT.java | 92 ++-
.../pass/IoTDBRegionMigrateNormalIT.java | 8 +-
.../pass/IoTDBRegionMigrateOtherIT.java | 9 +-
...ateCoordinatorCrashWhenRemoveRemotePeerIT.java} | 24 +-
.../IoTDBRegionMigrateDataNodeCrashIT.java | 59 +-
...MigrateOriginalCrashWhenDeleteLocalPeerIT.java} | 19 +-
...igrateOriginalCrashWhenRemoveRemotePeerIT.java} | 19 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 5 +
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 4 +
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 75 ++-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 4 +
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 4 +
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 13 +
.../pipe/it/manual/AbstractPipeDualManualIT.java | 4 +
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 4 +
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 4 +
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 1 +
.../it/dual/AbstractSubscriptionDualIT.java | 5 +
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 725 ++++++++++++++-------
.../it/dual/IoTDBSubscriptionTopicIT.java | 157 ++++-
.../it/local/IoTDBSubscriptionBasicIT.java | 12 +-
.../it/local/IoTDBSubscriptionIdempotentIT.java | 22 +-
.../it/local/IoTDBSubscriptionRestartIT.java | 298 ++++++++-
.../org/apache/iotdb/isession/SessionDataSet.java | 6 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 3 +-
.../rpc/subscription/config/ConsumerConstant.java | 17 +-
.../exception}/SubscriptionException.java | 2 +-
.../SubscriptionParameterNotValidException.java | 17 +-
.../SubscriptionPollTimeOutException.java | 16 +-
.../subscription/ConsumerHeartbeatWorker.java | 26 +-
.../subscription/PullConsumerAutoCommitWorker.java | 10 +-
.../session/subscription/SubscriptionConsumer.java | 383 +++++++++--
.../subscription/SubscriptionEndpointsSyncer.java | 131 ++++
.../session/subscription/SubscriptionProvider.java | 48 +-
.../subscription/SubscriptionPullConsumer.java | 99 ++-
.../subscription/SubscriptionPushConsumer.java | 2 +-
.../session/subscription/SubscriptionSession.java | 20 +-
.../SubscriptionSessionConnection.java | 15 -
.../session/subscription/model/Subscription.java | 6 +-
.../iotdb/session/subscription/model/Topic.java | 4 +-
iotdb-connector/grafana-plugin/yarn.lock | 16 +-
.../client/async/AsyncDataNodeClientPool.java | 10 +-
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../heartbeat/ConfigNodeHeartbeatHandler.java | 22 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 73 ++-
.../handlers/rpc/TransferLeaderRPCHandler.java | 89 +++
.../client/sync/SyncDataNodeClientPool.java | 9 +-
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 4 +-
.../confignode/conf/SystemPropertiesUtils.java | 7 +-
.../statemachine/ConfigRegionStateMachine.java | 3 +
.../iotdb/confignode/manager/ConfigManager.java | 44 +-
.../apache/iotdb/confignode/manager/IManager.java | 7 +
.../iotdb/confignode/manager/ProcedureManager.java | 19 +-
.../iotdb/confignode/manager/load/LoadManager.java | 139 ++--
.../manager/load/balancer/RouteBalancer.java | 416 +++++++-----
.../router/priority/GreedyPriorityBalancer.java | 4 +-
.../router/priority/LeaderPriorityBalancer.java | 4 +-
.../load/cache/AbstractHeartbeatSample.java} | 33 +-
.../manager/load/cache/AbstractLoadCache.java | 86 +++
.../manager/load/cache/AbstractStatistics.java | 49 ++
.../confignode/manager/load/cache/LoadCache.java | 284 ++++----
.../load/cache/consensus/ConsensusGroupCache.java | 61 ++
.../consensus/ConsensusGroupHeartbeatSample.java | 27 +-
.../cache/consensus/ConsensusGroupStatistics.java | 65 ++
.../manager/load/cache/node/BaseNodeCache.java | 106 +--
.../load/cache/node/ConfigNodeHeartbeatCache.java | 39 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 37 +-
.../load/cache/node/NodeHeartbeatSample.java | 70 +-
.../manager/load/cache/node/NodeStatistics.java | 94 +--
.../manager/load/cache/region/RegionCache.java | 56 +-
.../load/cache/region/RegionGroupCache.java | 96 +--
.../load/cache/region/RegionGroupStatistics.java | 80 +--
.../load/cache/region/RegionHeartbeatSample.java | 27 +-
.../load/cache/region/RegionStatistics.java | 38 +-
.../manager/load/cache/route/RegionRouteCache.java | 147 -----
.../manager/load/service/EventService.java | 272 ++++++++
.../manager/load/service/HeartbeatService.java | 26 +-
.../manager/load/service/StatisticsService.java | 237 +------
...va => ConsensusGroupStatisticsChangeEvent.java} | 30 +-
.../load/subscriber/IClusterStatusSubscriber.java | 8 +-
.../subscriber/NodeStatisticsChangeEvent.java} | 32 +-
....java => RegionGroupStatisticsChangeEvent.java} | 24 +-
.../iotdb/confignode/manager/node/NodeManager.java | 13 +-
.../receiver/IoTDBConfigNodeReceiverAgent.java | 21 +
.../runtime/PipeLeaderChangeHandler.java | 41 +-
.../runtime/PipeRuntimeCoordinator.java | 23 +-
.../pipe/execution/PipeConfigNodeSubtask.java | 9 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 36 +-
.../persistence/subscription/SubscriptionInfo.java | 2 +-
.../iotdb/confignode/procedure/Procedure.java | 15 -
.../procedure/env/ConfigNodeProcedureEnv.java | 45 +-
.../procedure/env/RegionMaintainHandler.java | 112 ++--
.../procedure/impl/StateMachineProcedure.java | 18 +
.../impl/node/AddConfigNodeProcedure.java | 10 +-
.../impl/region/AddRegionPeerProcedure.java | 91 ++-
.../impl/region/CreateRegionGroupsProcedure.java | 78 +--
.../impl/region/RemoveRegionPeerProcedure.java | 23 +-
.../impl/schema/DeleteDatabaseProcedure.java | 5 +-
.../AbstractOperateSubscriptionProcedure.java | 2 +-
.../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 +-
.../testonly/CreateManyDatabasesProcedure.java | 10 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +-
.../router/priority/GreedyPriorityTest.java | 10 +-
.../priority/LeaderPriorityBalancerTest.java | 8 +-
...CacheTest.java => ConsensusGroupCacheTest.java} | 20 +-
.../manager/load/cache/NodeCacheTest.java | 37 +-
.../manager/load/cache/RegionGroupCacheTest.java | 116 ++--
.../persistence/node/NodeStatisticsTest.java | 66 --
.../statistics/RegionGroupStatisticsTest.java | 76 ---
.../partition/statistics/RegionStatisticsTest.java | 66 --
iotdb-core/consensus/pom.xml | 4 +
.../org/apache/iotdb/consensus/IConsensus.java | 27 +
.../consensus/exception/ConsensusException.java | 4 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 102 ++-
.../consensus/iot/IoTConsensusServerImpl.java | 181 +++--
.../service/IoTConsensusRPCServiceProcessor.java | 8 +-
.../iot/snapshot/SnapshotFragmentReader.java | 4 +
.../iotdb/consensus/ratis/RatisConsensus.java | 54 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 16 +
.../apache/iotdb/consensus/iot/ReplicateTest.java | 21 +
.../apache/iotdb/consensus/iot/StabilityTest.java | 12 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 26 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 54 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 17 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 4 +-
.../dataregion/DataRegionStateMachine.java | 15 +-
.../db/exception/PartitionViolationException.java | 6 +-
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 2 +-
.../builder/PipeTransferBatchReqBuilder.java | 49 +-
.../async/IoTDBDataRegionAsyncConnector.java | 26 +
.../PipeTransferTabletBatchEventHandler.java | 12 +-
.../PipeTransferTabletInsertionEventHandler.java | 5 -
.../PipeTransferTsFileInsertionEventHandler.java | 2 -
.../protocol/websocket/WebSocketConnector.java | 6 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 4 +-
.../iotdb/db/pipe/metric/PipeConnectorMetrics.java | 46 +-
.../iotdb/db/pipe/metric/PipeExtractorMetrics.java | 49 +-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 46 +-
.../processor/aggregate/AggregateProcessor.java | 160 +++--
.../aggregate/TimeSeriesRuntimeState.java | 31 +-
.../window/datastructure/TimeSeriesWindow.java | 42 +-
.../window/datastructure/WindowOutput.java | 6 +-
.../processor/TumblingWindowingProcessor.java | 12 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 47 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 60 +-
.../thrift/IoTDBDataNodeReceiverAgent.java | 18 +
.../db/pipe/resource/memory/PipeMemoryBlock.java | 7 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 1 -
.../pipe/task/connection/PipeEventCollector.java | 8 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 3 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 2 +-
.../subtask/connector/PipeConnectorSubtask.java | 6 +-
.../connector/PipeConnectorSubtaskManager.java | 10 +-
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 9 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 69 +-
.../db/queryengine/common/MPPQueryContext.java | 17 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 4 +-
.../exchange/source/LocalSourceHandle.java | 9 -
.../queryengine/execution/memory/MemoryPool.java | 14 +-
.../execution/operator/source/SeriesScanUtil.java | 12 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 13 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 35 +-
.../analyze/cache/schema/DataNodeSchemaCache.java | 47 +-
.../analyze/cache/schema/SchemaCacheEntry.java | 8 +
.../cache/schema/TimeSeriesSchemaCache.java | 32 +
.../cache/schema/dualkeycache/IDualKeyCache.java | 9 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 59 ++
.../schema/lastcache/DataNodeLastCacheManager.java | 7 +
.../schema/lastcache/ILastCacheContainer.java | 5 +-
.../cache/schema/lastcache/LastCacheContainer.java | 7 +
.../analyze/lock/DataNodeSchemaLockManager.java | 59 ++
.../plan/analyze/lock/SchemaLockType.java | 51 ++
.../plan/analyze/schema/ClusterSchemaFetcher.java | 14 +-
.../config/executor/ClusterConfigTaskExecutor.java | 21 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 69 +-
.../iotdb/db/service/RegionMigrateService.java | 7 +-
.../db/storageengine/dataregion/DataRegion.java | 44 +-
.../exception/CompactionExceptionHandler.java | 15 +-
.../execute/recover/CompactionRecoverTask.java | 18 +-
.../execute/task/AbstractCompactionTask.java | 15 +-
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../compaction/repair/RepairDataFileScanUtil.java | 4 +
.../repair/RepairTimePartitionScanTask.java | 12 +
.../schedule/CompactionScheduleTaskManager.java | 4 +-
.../compaction/schedule/CompactionScheduler.java | 6 -
.../compaction/schedule/CompactionTaskQueue.java | 52 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../memtable/AlignedWritableMemChunk.java | 5 +-
.../dataregion/snapshot/SnapshotLoader.java | 6 -
.../storageengine/dataregion/tsfile/TsFileID.java | 18 +-
.../dataregion/tsfile/TsFileManager.java | 2 +-
.../tsfile/timeindex/DeviceTimeIndex.java | 64 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 22 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 2 -
.../wal/recover/file/TsFilePlanRedoer.java | 8 +-
.../file/UnsealedTsFileRecoverPerformer.java | 12 +-
.../agent/SubscriptionAgentLauncher.java | 2 +-
.../agent/SubscriptionConsumerAgent.java | 2 +-
.../receiver/SubscriptionReceiverV1.java | 7 +-
.../task/stage/SubscriptionTaskConnectorStage.java | 2 +-
.../SubscriptionConnectorSubtaskManager.java | 12 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 27 -
.../cache/dualkeycache/DualKeyCacheTest.java | 114 ++++
.../inner/InnerSpaceCompactionExceptionTest.java | 5 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 36 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 87 +++
.../metrics/metricsets/system/SystemMetrics.java | 149 ++++-
.../apache/iotdb/metrics/utils/SystemMetric.java | 1 +
.../resources/conf/iotdb-common.properties | 3 +-
.../src/assembly/resources/sbin/health_check.bat | 641 ++++++++++++++++++
.../src/assembly/resources/sbin/health_check.sh | 388 +++++++++++
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 10 +
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 8 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 54 ++
.../iotdb/commons/path/PathPatternTreeUtils.java | 22 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../config/constant/PipeExtractorConstant.java | 2 +-
.../listening/AbstractPipeListeningQueue.java | 6 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 28 +-
.../pipe/progress/PipeEventCommitManager.java | 26 +-
.../commons/pipe/progress/PipeEventCommitter.java | 15 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 263 +++++---
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 46 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 2 +-
.../pipe/task/subtask/PipeReportableSubtask.java | 2 +-
.../commons/pipe/task/subtask/PipeSubtask.java | 18 +-
.../meta/consumer/ConsumerGroupMeta.java | 2 +-
.../iotdb/commons/utils/CommonDateTimeUtils.java | 32 +
... => IoTConsensusDeleteLocalPeerKillPoints.java} | 8 +-
...a => IoTConsensusInactivatePeerKillPoints.java} | 8 +-
...TConsensusRemovePeerCoordinatorKillPoints.java} | 2 +-
...nsusRemovePeerKillPoints.java => KillNode.java} | 11 +-
.../consumer/ConsumerGroupDeSerTest.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 4 +-
.../src/main/thrift/confignode.thrift | 8 +-
.../src/main/thrift/iotconsensus.thrift | 1 +
.../src/main/thrift/datanode.thrift | 8 +-
pom.xml | 4 +-
269 files changed, 7676 insertions(+), 3484 deletions(-)
copy
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusException.java
=>
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionMigrateDataNodeCrashITFramework.java
(65%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/SubscriptionException.java
=>
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/KillPointContext.java
(61%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/IoTDBRegionMigrateClusterCrashIT.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/{notpass/datanodecrash/CoordinatorRemoveRemotePeerCrashIT.java
=>
pass/datanodecrash/IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerIT.java}
(64%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/{notpass
=> pass}/datanodecrash/IoTDBRegionMigrateDataNodeCrashIT.java (58%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{IoTDBRegionMigrateNormalIT.java
=> datanodecrash/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerIT.java}
(65%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{IoTDBRegionMigrateNormalIT.java
=> datanodecrash/IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerIT.java}
(64%)
copy
{iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/subscription
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception}/SubscriptionException.java
(96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/subscription/SubscriptionException.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionParameterNotValidException.java
(64%)
rename
{iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/subscription
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception}/SubscriptionPollTimeOutException.java
(69%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionEndpointsSyncer.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/TransferLeaderRPCHandler.java
copy
iotdb-core/confignode/src/{test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCacheTest.java
=>
main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractHeartbeatSample.java}
(51%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractStatistics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupCache.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/AbstractPipeSingleIT.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupHeartbeatSample.java
(60%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupStatistics.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/route/RegionRouteCache.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{RouteChangeEvent.java
=> ConsensusGroupStatisticsChangeEvent.java} (52%)
rename
iotdb-core/confignode/src/{test/java/org/apache/iotdb/confignode/manager/load/cache/RegionRouteCacheTest.java
=>
main/java/org/apache/iotdb/confignode/manager/load/subscriber/NodeStatisticsChangeEvent.java}
(51%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{StatisticsChangeEvent.java
=> RegionGroupStatisticsChangeEvent.java} (65%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/{LoadCacheTest.java
=> ConsensusGroupCacheTest.java} (58%)
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/node/NodeStatisticsTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionGroupStatisticsTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionStatisticsTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/lock/DataNodeSchemaLockManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/lock/SchemaLockType.java
create mode 100644
iotdb-core/node-commons/src/assembly/resources/sbin/health_check.bat
create mode 100644
iotdb-core/node-commons/src/assembly/resources/sbin/health_check.sh
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/KillPoint/{IoTConsensusRemovePeerKillPoints.java
=> IoTConsensusDeleteLocalPeerKillPoints.java} (86%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/KillPoint/{IoTConsensusRemovePeerKillPoints.java
=> IoTConsensusInactivatePeerKillPoints.java} (86%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/KillPoint/{IoTConsensusRemovePeerKillPoints.java
=> IoTConsensusRemovePeerCoordinatorKillPoints.java} (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/KillPoint/{IoTConsensusRemovePeerKillPoints.java
=> KillNode.java} (86%)
