fn build_sink_coordinator(
sink_param: SinkParam,
iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>,
) -> SinkCommitCoordinatorfn build_sink_coordinator(
sink_param: SinkParam,
iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>,
) -> SinkCommitCoordinator