Thanks, Nishu. On Fri, Nov 17, 2017 at 4:47 PM, Nishu <nishuta...@gmail.com> wrote:
> 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 <sushil...@gmail.com> 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 >
