Hey, I'm having issues with running a simple pipeline on a remote Flink cluster. I use a separate Beam job server to which I submit the job, which then goes to the Flink cluster with docker-in-docker enabled. For some reason, I'm getting errors in Flink which I can't decipher (see gist <https://gist.github.com/nirga/351d59dac972cb20786da7094161e748>).
Can someone assist me? Thanks! Nir
