This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch global-counter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8d40be517eb count points
add 0e5e2462b45 Optimize region migration log && change region status to
removing before transferring leader (#12368)
add 9399399292b Fix IoTConsensus LogDispatcherThread Stop Using Futrue
Cancel (#12370)
add 68c7fc26d62 Pipe: clear reference count for events in retry queue &
detect re-increasing reference count for other connectors (#12344)
add bd5d999148e release chunk or page memory when deserializing chunk or
page (#12340)
add 7004e4d8eed Subscription: Push consumer & Async commit (#12294)
add 91abf72975b Optimize the input parameters for LeaderBalancer (#12374)
add dc33f7a88a4 fix(jdbc): when parameter is string ,append "\"" (#12371)
add a6ea99bce6e Merge branch 'master' of https://github.com/apache/iotdb
into global-counter
No new revisions were added by this update.
Summary of changes:
.../pass/IoTDBRegionMigrateClusterCrashIT.java | 3 +-
.../pass/IoTDBRegionMigrateConfigNodeCrashIT.java | 2 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 260 ++++++++++++++++++++-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 7 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 23 ++
.../rpc/subscription/config/ConsumerConstant.java | 7 +-
...riptionMessagePayload.java => AckStrategy.java} | 10 +-
...essagePayload.java => AsyncCommitCallback.java} | 10 +-
...ionMessagePayload.java => ConsumeListener.java} | 5 +-
...ptionMessagePayload.java => ConsumeResult.java} | 5 +-
.../session/subscription/SubscriptionConsumer.java | 136 ++++++++++-
.../subscription/SubscriptionPullConsumer.java | 67 ++----
.../subscription/SubscriptionPushConsumer.java | 192 ++++++++++++++-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 4 +-
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 6 +-
.../manager/load/balancer/RouteBalancer.java | 19 +-
.../router/leader/AbstractLeaderBalancer.java | 108 +++++++++
.../router/leader/GreedyLeaderBalancer.java | 57 ++---
.../balancer/router/leader/ILeaderBalancer.java | 49 ----
.../router/leader/MinCostFlowLeaderBalancer.java | 123 ++++------
.../confignode/manager/load/cache/LoadCache.java | 59 ++++-
.../manager/load/cache/node/NodeStatistics.java | 9 +
.../load/cache/region/RegionStatistics.java | 7 +
.../protocol/IoTDBConfigRegionAirGapConnector.java | 38 ++-
.../protocol/IoTDBConfigRegionConnector.java | 34 ++-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 3 +-
.../procedure/env/RegionMaintainHandler.java | 9 +-
.../impl/region/AddRegionPeerProcedure.java | 46 +++-
.../impl/region/RegionMigrateProcedure.java | 41 ++--
.../impl/region/RemoveRegionPeerProcedure.java | 39 +++-
.../procedure/state/RegionTransitionState.java | 1 -
.../procedure/state/RemoveRegionPeerState.java | 1 +
.../router/leader/CFDLeaderBalancerTest.java | 117 +++++++++-
.../router/leader/GreedyLeaderBalancerTest.java | 118 ++++++----
.../leader/LeaderBalancerComparisonTest.java | 75 +++++-
.../consensus/iot/logdispatcher/LogDispatcher.java | 27 ++-
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 17 +-
.../builder/PipeTransferBatchReqBuilder.java | 32 +--
.../airgap/IoTDBDataNodeAirGapConnector.java | 26 ++-
.../airgap/IoTDBDataRegionAirGapConnector.java | 86 +++++--
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 22 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 84 +++++--
.../connector/protocol/opcua/OpcUaConnector.java | 52 ++++-
.../async/IoTDBDataRegionAsyncConnector.java | 98 +++++---
.../PipeTransferTabletBatchEventHandler.java | 28 +--
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 17 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 90 +++++--
.../thrift/sync/IoTDBSchemaRegionConnector.java | 19 +-
.../protocol/writeback/WriteBackConnector.java | 51 +++-
.../schema/PipeSchemaRegionSnapshotEvent.java | 3 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 45 ++--
.../fast/AlignedSeriesCompactionExecutor.java | 68 ++----
.../fast/NonAlignedSeriesCompactionExecutor.java | 21 +-
.../executor/fast/element/AlignedPageElement.java | 7 +-
.../fast/element/NonAlignedPageElement.java | 3 +-
.../fast/reader/CompactionChunkReader.java | 33 ++-
.../broker/SerializedEnrichedEvent.java | 8 +-
.../pipe/connector/PipeReceiverStatusHandler.java | 21 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 74 ++++--
.../commons/pipe/task/subtask/PipeSubtask.java | 14 +-
61 files changed, 1966 insertions(+), 676 deletions(-)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{SubscriptionMessagePayload.java
=> AckStrategy.java} (83%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{SubscriptionMessagePayload.java
=> AsyncCommitCallback.java} (84%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{SubscriptionMessagePayload.java
=> ConsumeListener.java} (88%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{SubscriptionMessagePayload.java
=> ConsumeResult.java} (92%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/AbstractLeaderBalancer.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/ILeaderBalancer.java
