From 16821b20cc1a04db24b23623ff36353c1de6a58c Mon Sep 17 00:00:00 2001
From: linrunqi08 <linrunqi08@163.com>
Date: Mon, 27 Nov 2023 10:21:54 +0800
Subject: [PATCH] fix block event

---
 core/event/BlockEventManager.h | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/core/event/BlockEventManager.h b/core/event/BlockEventManager.h
index ec9a11b1cb..0ad5fcdfc7 100644
--- a/core/event/BlockEventManager.h
+++ b/core/event/BlockEventManager.h
@@ -50,7 +50,11 @@ class BlockedEventManager : public LogstoreFeedBackInterface {
         BlockedEvent() : mLogstoreKey(0), mEvent(NULL), mInvalidTime(time(NULL)), mTimeout(1) {}
         void Update(const LogstoreFeedBackKey& logstoreKey, Event* pEvent, int32_t curTime) {
             if (mEvent != NULL) {
-                delete mEvent;
+                if (!pEvent->IsReaderFlushTimeout() || mEvent->IsReaderFlushTimeout()) {
+                    delete mEvent;
+                } else {
+                    return;
+                }
             }
             mEvent = pEvent;
             mLogstoreKey = logstoreKey;