This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch pipe-garbage-cleaning
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dc3aa4e715b fix
add 57af70db88d fix
No new revisions were added by this update.
Summary of changes:
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 11 ++----
.../source/dataregion/IoTDBDataRegionSource.java | 2 +-
.../PipeRealtimeDataRegionHybridSource.java | 34 ++----------------
.../realtime/PipeRealtimeDataRegionLogSource.java | 42 ++++------------------
.../realtime/PipeRealtimeDataRegionSource.java | 35 ++----------------
.../PipeRealtimeDataRegionTsFileSource.java | 18 ++--------
.../TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../task/connection/BlockingPendingQueue.java | 21 +----------
9 files changed, 20 insertions(+), 147 deletions(-)
