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
