diff --git a/src/stream/src/executor/sink.rs b/src/stream/src/executor/sink.rs index 52377c49c322a..ee411e617196c 100644 --- a/src/stream/src/executor/sink.rs +++ b/src/stream/src/executor/sink.rs @@ -196,6 +196,9 @@ impl SinkExecutor { 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 {