numaflow
numaflow copied to clipboard
Fix channel ownership in MapStreaming
Today the channel can be closed by either user or numa; we should make sure only numa can close that channel, as numa owns the channel.