Hi Will,
assuming you are using Beam 2.0.0, the Flink runner uses Flink 1.2.1 by default.
So, I would recommend this version or 1.2.x.
Regards
JB
On 06/28/2017 10:39 PM, Will Walters wrote:
Hello,
I've been attempting to run Beam through Flink on a Yarn cluster and have run
into trouble with getting a job to submit, partly because of incompatibility
between versions. Does anyone know what versions of Beam and Flink I should be
using to give myself the best chance of finding compatibility?
Thank you,
Will.
--
Jean-Baptiste Onofré
[email protected]
http://blog.nanthrax.net
Talend - http://www.talend.com
