add log

risingwavelabs · Jun 18, 2024 · cae66b8 · cae66b8
1 parent d1a2aad
commit cae66b8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/stream/src/executor/sink.rs b/src/stream/src/executor/sink.rs
@@ -196,6 +196,9 @@ impl<F: LogStoreFactory> SinkExecutor<F> {
             metrics.sink_chunk_buffer_size,
         );
 
+        tracing::info!("Sink info: sink_id: {} actor_id: {}, executor_id: {}, need_advance_delete: {}, re_construct_with_sink_pk: {}",
+                        sink_id, actor_id, executor_id, need_advance_delete, re_construct_with_sink_pk);
+
         if self.sink.is_sink_into_table() {
             processed_input.boxed()
         } else {