First, a small correction for my previous mail:
I could reproduce your problems locally when submitting the fat-jar.
Turns out i never submitted the far-jar, as i didn't pass the jar file argument to RemoteEnvironment.
Now on to your questions:
What version of Flink are you trying with?
I got it working once with 1.6-SNAPSHOT, but i would recommend sticking with 1.3.1 since that is the version gradoop depends on. (i haven't tried it with this version yet, but that's the next thing on my list)
Are there other config changes (flink-conf.yaml) that you made in your cluster?
It was the standard config.
Is org.apache.flink.api.common.io.FileOutputFormat a good alternative to LocalCollectionOutputFormat?
It can be used, but if the result is small you could also use accumulators.
Do you think it is better to use jarFiles argument on createRemoteEnvironment?
Yes, once we get it working this is the way to go.
On 26.04.2018 18:42, kedar mhaswade wrote: