Just a heads up. I haven't found the root cause for this issue yet but
restarting all the nodes seems to have solved this issue.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
I'm using Flink 1.4.2
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Could you tell us which Flink version you are using?
On 28.05.2018 14:01, HarshithBolar wrote:
I'm submitting a Flink job to a cluster that has three Task Managers via the
Flink dashboard. When I set `Parallelism` to 1 (which is default),
everything runs as expected. But when I increase `Paralle
I'm submitting a Flink job to a cluster that has three Task Managers via the
Flink dashboard. When I set `Parallelism` to 1 (which is default),
everything runs as expected. But when I increase `Parallelism` to anything
more than 1, the job fails with the exception,
/java.io.FileNotFoundExcepti
