Thanks Ismael, I was looking for something like that. Amit: yes. It's only hard coded for the purpose of replicating a bug.
2016-06-01 14:38 GMT+02:00 Amit Sela <[email protected]>: > Did you try changing FlinkPipelineOptions and FlinkPipelineRunner to > Spark's equivalents ? It looks like it's hard coded to run on Flink. > > On Wed, Jun 1, 2016 at 3:23 PM Ismaël Mejía <[email protected]> wrote: > >> You can find my pom.xml file for my beam-playground project that runs in >> the spark runner, note that it uses the daily snapshots, but I will change >> it for the released jars once they are on maven central: >> >> https://github.com/iemejia/beam-playground/blob/master/pom.xml >> >> Regards, >> Ismaël >> >> On Wed, Jun 1, 2016 at 3:01 AM, Pawel Szczur <[email protected]> >> wrote: >> >>> Hi, >>> >>> A Beam can be easily configured to run against Direct, Dataflow and >>> Flink, but I couldn't get Spark to work. >>> >>> Here's a repo I've prepared for a bug reproduction, it may serve as init: >>> https://github.com/orian/cogroup-wrong-grouping >>> >>> Could someone modify it or share some working example (outside of Beam >>> repo). >>> >>> Cheers, Pawel >>> >> >>
