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
