Hi Sushil, I also faced the similar issue last week and reported to the team. There is an issue with Spark runner when you run the pipeline in streaming mode. Issue has been logged into JIRA : https://issues.apache.org/jira/browse/BEAM-3193.
Regards, Nishu On Fri, Nov 17, 2017 at 11:50 AM, Sushil Ks <[email protected]> wrote: > 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 > -- Thanks & Regards, Nishu Tayal
