add log

risingwavelabs · Jun 18, 2024 · 4ae9444 · 4ae9444
1 parent d1a2aad
commit 4ae9444
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
@@ -184,6 +184,9 @@ impl<F: LogStoreFactory> SinkExecutor<F> {
         let re_construct_with_sink_pk = need_advance_delete
             && self.sink_param.sink_type == SinkType::Upsert
             && !self.sink_param.downstream_pk.is_empty();
+        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);
+
         let processed_input = Self::process_msg(
             input,
             self.sink_param.sink_type,