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 aad2caa9f22 Fix flush old leader NPE when rebanlce #14981
add 3384bd69a92 Subscription: add parameter to the clean up method to
distinguish the force close situation & fix reference count management for
iteration snapshot (#14966)
No new revisions were added by this update.
Summary of changes:
.../broker/SubscriptionPrefetchingQueue.java | 10 +++++-----
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../iotdb/db/subscription/event/SubscriptionEvent.java | 4 ++--
.../event/batch/SubscriptionPipeEventBatch.java | 2 +-
.../event/batch/SubscriptionPipeEventBatches.java | 2 +-
.../event/batch/SubscriptionPipeTabletEventBatch.java | 6 +++---
.../batch/SubscriptionPipeTabletIterationSnapshot.java | 18 +++++++++++++++++-
.../event/batch/SubscriptionPipeTsFileEventBatch.java | 2 +-
.../event/pipe/SubscriptionPipeEmptyEvent.java | 2 +-
.../event/pipe/SubscriptionPipeEvents.java | 2 +-
.../event/pipe/SubscriptionPipeTabletBatchEvents.java | 11 ++++++++---
.../event/pipe/SubscriptionPipeTsFileBatchEvents.java | 4 ++--
.../event/pipe/SubscriptionPipeTsFilePlainEvent.java | 2 +-
14 files changed, 45 insertions(+), 24 deletions(-)
