pub fn refill_upstream_sink_union_in_table(
union_fragment_root: &mut PbStreamNode,
upstream_sink_infos: &Vec<UpstreamSinkInfo>,
)pub fn refill_upstream_sink_union_in_table(
union_fragment_root: &mut PbStreamNode,
upstream_sink_infos: &Vec<UpstreamSinkInfo>,
)