Hi,
I have configured multiple triggers on an *UnboundedSource* for
a Beam Pipeline with *GroupByKey* and works as expected on DirectRunner.
However, when I deploy on the SparkCluster its seems to not apply the
*GroupByKey* transformation at all. Is this expected? if so any help to get
unblocked would be appreciated.Regards, Sushil Ks
