From d1d43c511e6d480d78d39a4d1fd14354bab7fa36 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=84=E9=A3=8F?= <yangzehua.yzh@alibaba-inc.com>
Date: Mon, 25 Nov 2024 11:06:06 +0000
Subject: [PATCH] fix bug

---
 core/models/MetricValue.cpp   | 6 +++---
 core/models/MetricValue.h     | 6 +++---
 core/runner/FlusherRunner.cpp | 4 ++--
 3 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/core/models/MetricValue.cpp b/core/models/MetricValue.cpp
index 3a8618c64a..c262367e07 100644
--- a/core/models/MetricValue.cpp
+++ b/core/models/MetricValue.cpp
@@ -56,15 +56,15 @@ void UntypedMultiDoubleValues::DelValue(StringView key) {
     mValues.erase(key);
 }
 
-std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::MultiKeyValusBegin() const {
+std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::ValusBegin() const {
     return mValues.begin();
 }
 
-std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::MultiKeyValusEnd() const {
+std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::ValusEnd() const {
     return mValues.end();
 }
 
-size_t UntypedMultiDoubleValues::MultiKeyValusSize() const {
+size_t UntypedMultiDoubleValues::ValusSize() const {
     return mValues.size();
 }
 
diff --git a/core/models/MetricValue.h b/core/models/MetricValue.h
index 67774c7e2f..b3caef108c 100644
--- a/core/models/MetricValue.h
+++ b/core/models/MetricValue.h
@@ -58,9 +58,9 @@ struct UntypedMultiDoubleValues {
     void SetValueNoCopy(StringView key, double val);
     void DelValue(StringView key);
 
-    std::map<StringView, double>::const_iterator MultiKeyValusBegin() const;
-    std::map<StringView, double>::const_iterator MultiKeyValusEnd() const;
-    size_t MultiKeyValusSize() const;
+    std::map<StringView, double>::const_iterator ValusBegin() const;
+    std::map<StringView, double>::const_iterator ValusEnd() const;
+    size_t ValusSize() const;
 
     size_t DataSize() const;
     void ResetPipelineEvent(PipelineEvent* ptr) { mMetricEventPtr = ptr; }
diff --git a/core/runner/FlusherRunner.cpp b/core/runner/FlusherRunner.cpp
index 1f9f808371..42a1b452fa 100644
--- a/core/runner/FlusherRunner.cpp
+++ b/core/runner/FlusherRunner.cpp
@@ -186,13 +186,13 @@ void FlusherRunner::Dispatch(SenderQueueItem* item) {
             if (!BOOL_FLAG(enable_full_drain_mode) && Application::GetInstance()->IsExiting()
                 && item->mFlusher->Name() == "flusher_sls") {
                 DiskBufferWriter::GetInstance()->PushToDiskBuffer(item, 3);
-                SenderQueueManager::GetInstance()->RemoveItem(item->mFlusher->GetQueueKey(), item);
+                SenderQueueManager::GetInstance()->RemoveItem(item->mQueueKey, item);
             } else {
                 PushToHttpSink(item);
             }
             break;
         default:
-            SenderQueueManager::GetInstance()->RemoveItem(item->mFlusher->GetQueueKey(), item);
+            SenderQueueManager::GetInstance()->RemoveItem(item->mQueueKey, item);
             break;
     }
 }