This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 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)
No new revisions were added by this update.
Summary of changes:
.../protocol/IoTDBConfigRegionAirGapConnector.java | 38 ++++++++-
.../protocol/IoTDBConfigRegionConnector.java | 34 +++++++-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 3 +-
...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 +++++-----
.../broker/SerializedEnrichedEvent.java | 8 +-
.../pipe/connector/PipeReceiverStatusHandler.java | 21 +++--
.../iotdb/commons/pipe/event/EnrichedEvent.java | 74 +++++++++++-----
.../commons/pipe/task/subtask/PipeSubtask.java | 14 ++--
22 files changed, 622 insertions(+), 240 deletions(-)
