Function try_get_iceberg_table_by_downstream_sink 

pub async fn try_get_iceberg_table_by_downstream_sink<C>(
    txn: &C,
    sink_id: SinkId,
) -> MetaResult<Option<TableId>>
where
    C: ConnectionTrait,