Flink error: java.io.IOException: Temporary file directory {dir} does not exist

error:
 EXCEPTIONS: java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.net.ConnectException: Connection refused
java.io.IOException: Temporary file directory /mnt/vol2/tmp/flink-cluster-tmp does not exist.
java.io.IOException: Temporary file directory /mnt/vol2/tmp/flink-cluster-tmp does not exist.
java.io.IOException: Temporary file directory /mnt/vol2/tmp/flink-cluster-tmp does not exist.
java.io.IOException: Temporary file directory /mnt/vol2/tmp/flink-cluster-tmp does not exist.
java.net.ConnectException: Connection refused
In logs:
2018-05-04 10:00:16,043 INFO  org.apache.flink.yarn.YarnJobManager              - Container container_e59_1524774482521_9399_01_000010 is completed with diagnostics: Exception from container-launch.
Container id: container_e59_1524774482521_9399_01_000010
Exit code: 1
Stack trace: ExitCodeException exitCode=1: 
	at org.apache.hadoop.util.Shell.runCommand(Shell.java:543)
	at org.apache.hadoop.util.Shell.run(Shell.java:460)
	at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:720)
	at org.apache.hadoop.yarn.server.nodemanager.DefaultContainerExecutor.launchContainer(DefaultContainerExecutor.java:210)
	at org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher.ContainerLaunch.call(ContainerLaunch.java:302)
	at org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher.ContainerLaunch.call(ContainerLaunch.java:82)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Create the necessary directories defined in flink conf file and with correct 
permissions, this issue will be fixed.
0 Comments

There are no comments yet

Leave a comment

Your email address will not be published. Required fields are marked *