update user_source_reader_error

risingwavelabs · Mar 11, 2024 · a2efd74 · a2efd74
1 parent fe7ca09
commit a2efd74
Showing 1 changed file with 3 additions and 4 deletions.
diff --git 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