From a2efd74d5377f58df1f516cf60897207b58a9317 Mon Sep 17 00:00:00 2001
From: xxchan <xxchan22f@gmail.com>
Date: Mon, 11 Mar 2024 14:38:35 +0800
Subject: [PATCH] update user_source_reader_error

---
 src/stream/src/executor/source/source_backfill_executor.rs | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/stream/src/executor/source/source_backfill_executor.rs b/src/stream/src/executor/source/source_backfill_executor.rs
index 7ec3e73965991..c1935b9d485aa 100644
--- a/src/stream/src/executor/source/source_backfill_executor.rs
+++ b/src/stream/src/executor/source/source_backfill_executor.rs
@@ -376,12 +376,11 @@ impl<S: StateStore> SourceBackfillExecutorInner<S> {
                                 source_id = %core.source_id,
                                 "stream source reader error",
                             );
-                            GLOBAL_ERROR_METRICS.user_source_reader_error.report([
+                            GLOBAL_ERROR_METRICS.user_source_error.report([
                                 "SourceReaderError".to_owned(),
-                                e.to_report_string(),
-                                "SourceExecutor".to_owned(),
-                                self.actor_ctx.id.to_string(),
                                 core.source_id.to_string(),
+                                core.source_name.to_owned(),
+                                self.actor_ctx.fragment_id.to_string(),
                             ]);
 
                             let reader = self