Is there some periodic cleanup job
running on your system for /tmp?
On 11.03.2019 10:38, Alexander Smirnov wrote:
Hi
everybody,
I
am using Flink 1.4.2 and periodically my job goes down with
the following exception in logs. Relaunching
the job does not help, only restarting the whole cluster.
Is there a JIRA problem for that?
will upgrade to 1.5 help?
java.io.FileNotFoundException:
/tmp/flink-io-20a15b29-1838-4de0-b383-165b1c49655c/c41ceb40a4eca0d0b739e0d1e2db45b9cc22d160ef25769993084a90e6a79b78.0.buffer
(No such file or directory)
at
java.io.RandomAccessFile.open0(Native Method)
at
java.io.RandomAccessFile.open(RandomAccessFile.java:316)
at
java.io.RandomAccessFile.(RandomAccessFile.java:243)
at
org.apache.flink.streaming.runtime.io.BufferSpiller.createSpillingChannel(BufferSpiller.java:259)
at
org.apache.flink.streaming.runtime.io.BufferSpiller.(BufferSpiller.java:120)
at
org.apache.flink.streaming.runtime.io.BarrierBuffer.(BarrierBuffer.java:149)
at
org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.(StreamTwoInputProcessor.java:147)
at
org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask.init(TwoInputStreamTask.java:79)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:235)
at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
at
java.lang.Thread.run(Thread.java:748)
Thank
you,
Alex
Locked
