Hi,
I have seen the compatibility matrix and I realize that Spark is not the
most supported runner.
I am curious if it is possible to run a pipeline on Spark, say with global
windows, after processing triggers and group by key(CoGroupByKye,
CombineByKey) . We have definitely problems to execute a pipeline that
successfully runs on direct runner.

Is that a known issue? Is Flink the best option?

Best Regards
Artur

Reply via email to