temp add more log

risingwavelabs · Nov 4, 2024 · cc1def9 · cc1def9
1 parent 27df405
commit cc1def9
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/stream/src/executor/backfill/cdc/cdc_backfill.rs b/src/stream/src/executor/backfill/cdc/cdc_backfill.rs
@@ -487,7 +487,8 @@ impl<S: StateStore> CdcBackfillExecutor<S> {
                                     // just use the last row to update `current_pos`.
                                     current_pk_pos = Some(get_new_pos(&chunk, &pk_indices));
 
-                                    tracing::trace!(
+                                    // TODO: revert log level
+                                    tracing::error!(
                                         "got a snapshot chunk: len {}, current_pk_pos {:?}",
                                         chunk.cardinality(),
                                         current_pk_pos
@@ -564,7 +565,8 @@ impl<S: StateStore> CdcBackfillExecutor<S> {
                             total_snapshot_row_count += row_count;
                             snapshot_read_row_cnt += row_count as usize;
 
-                            tracing::debug!(
+                            // TODO: revert log level
+                            tracing::error!(
                                 table_id,
                                 ?current_pk_pos,
                                 ?snapshot_read_row_cnt,