pub(crate) async fn cleanup_dropped_sink_runtimes(
sink_manager: &SinkCoordinatorManager,
iceberg_pk_index_sink_manager: &IcebergPkIndexSinkManager,
streaming_job_ids: impl IntoIterator<Item = JobId>,
)Expand description
Stop sink runtimes after catalog deletion, even when the drop barrier fails.