Oh okay! Thanks Jean. On Nov 17, 2017 6:02 PM, "Jean-Baptiste Onofré" <[email protected]> wrote:
> Hi, > > I think it's related to the identified issue: > > https://issues.apache.org/jira/browse/BEAM-3193 > > I'm working on a fix. > > To avoid to mix different change in the runner, I'm holding the fix a bit > due to the Spark 2 update. > > Regards > JB > > On 11/17/2017 11:50 AM, Sushil Ks 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 >> > > -- > Jean-Baptiste Onofré > [email protected] > http://blog.nanthrax.net > Talend - http://www.talend.com >
