This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch leader-balance-constraint
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3db04ac8f33 Finish
add c82bcdb4ab2 Increase region migration pool size on DataNode (#12366)
add e03b9be05ad Pipe: Fixed the bug that mod file may not close in async
transferring (#12347)
add fa2a14a1a7e Pipe: Added debug logger after schema/config event is
successfully transferred (#12362)
add 68265373a0b Pipe: Make the PipeParameters return sorted entries string
when "toString" is called (#12329)
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 b7a6fb7e192 Merge branch 'master' into leader-balance-constraint
No new revisions were added by this update.
Summary of changes:
.../pass/IoTDBRegionMigrateClusterCrashIT.java | 3 +-
.../pass/IoTDBRegionMigrateConfigNodeCrashIT.java | 2 +-
.../api/customizer/parameter/PipeParameters.java | 77 +++++++++--------
.../protocol/IoTDBConfigRegionAirGapConnector.java | 38 ++++++++-
.../protocol/IoTDBConfigRegionConnector.java | 78 ++++++++++++-----
.../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 +
.../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 ++-----
.../PipeTransferTsFileInsertionEventHandler.java | 26 +++---
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 39 ++++++---
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 90 +++++++++++++++-----
.../thrift/sync/IoTDBSchemaRegionConnector.java | 33 ++++++--
.../protocol/writeback/WriteBackConnector.java | 51 ++++++++---
.../schema/PipeSchemaRegionSnapshotEvent.java | 3 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 45 +++++-----
.../iotdb/db/service/RegionMigrateService.java | 3 +-
.../broker/SerializedEnrichedEvent.java | 8 +-
.../pipe/connector/PipeReceiverStatusHandler.java | 21 +++--
.../iotdb/commons/pipe/event/EnrichedEvent.java | 74 +++++++++++-----
.../commons/pipe/task/subtask/PipeSubtask.java | 14 ++--
34 files changed, 839 insertions(+), 378 deletions(-)
