This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-pipe-ref-count-leak
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9acc0e40bef Update EnrichedEvent.java
add 9ebc25cdb76 Update EnrichedEvent.java
add dd4b4474a42 fix
No new revisions were added by this update.
Summary of changes:
.../protocol/IoTDBConfigRegionAirGapConnector.java | 20 +++++------
.../protocol/IoTDBConfigRegionConnector.java | 20 +++++------
.../evolvable/batch/PipeTabletEventBatch.java | 7 ++--
.../airgap/IoTDBDataNodeAirGapConnector.java | 10 +++---
.../airgap/IoTDBDataRegionAirGapConnector.java | 30 ++++++++--------
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 10 +++---
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 30 ++++++++--------
.../connector/protocol/opcua/OpcUaConnector.java | 18 +++++-----
.../pipeconsensus/PipeConsensusAsyncConnector.java | 4 ---
.../pipeconsensus/PipeConsensusSyncConnector.java | 10 +++---
.../async/IoTDBDataRegionAsyncConnector.java | 6 ----
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 10 +++---
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 30 ++++++++--------
.../thrift/sync/IoTDBSchemaRegionConnector.java | 10 +++---
.../protocol/websocket/WebSocketConnector.java | 9 +++--
.../protocol/writeback/WriteBackConnector.java | 18 +++++-----
.../PipeHistoricalDataRegionTsFileExtractor.java | 42 +++++++++++++++-------
.../realtime/assigner/PipeDataRegionAssigner.java | 25 +++++++++++--
.../pipe/task/connection/PipeEventCollector.java | 8 +++--
.../iotdb/commons/pipe/event/EnrichedEvent.java | 16 ++++++---
20 files changed, 188 insertions(+), 145 deletions(-)
