While implementing a runner, we tried annotating a CombineByKey transform.
I noticed that the annotations for the CBK are then lost in the fusion
optimization stage when the CBK is broken into components. Is this
intentional?

I can put up a PR if this seems worth fixing (it is for us at least), just
want to confirm before doing so

Reply via email to