minor

risingwavelabs · Jan 24, 2024 · cd86185 · cd86185
1 parent 9a4241e
commit cd86185
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/stream/src/executor/backfill/cdc/cdc_backfill.rs b/src/stream/src/executor/backfill/cdc/cdc_backfill.rs
@@ -542,7 +542,7 @@ fn mapping_message(
                     GLOBAL_ERROR_METRICS.cdc_source_error.report([
                         upstream_table_name.into(),
                         upstream_table_id.to_string(),
-                        e.to_string().into(),
+                        e.to_string(),
                     ]);
                     None
                 }
@@ -551,6 +551,7 @@ fn mapping_message(
     }
 }
 
+/// filter out upstream events occurred before `last_cdc_offset`
 fn mark_upstream_chunk(
     chunk: StreamChunk,
     offset_parse_func: &CdcOffsetParseFunc,