Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via flink-user by ANDREA SPINA, 1 year ago
The program execution failed: Job execution failed.
via apache.org by Unknown author, 2 years ago
via flink-user by Theodore Vasiloudis, 1 year ago
The program execution failed: Job execution failed.
via flink-user by Timur Fayruzov, 1 year ago
The program execution failed: Failed to submit job fc13373d993539e647f164e12d82bf90 (WordCount Example)
via flink-user by Lydia Ickler, 1 year ago
The program execution failed: Cannot initialize task 'DataSink (CsvOutputFormat (path: hdfs://grips2:9000/users/Wordcount_1000s, delimiter: ))': Output directory could not be created.
via flink-user by Till Rohrmann, 1 year ago
The program execution failed: Cannot initialize task 'DataSink (CsvOutputFormat (path: hdfs://grips2:9000/users/Wordcount_1000s, delimiter: ))': Output directory could not be created.
java.io.IOException: Channel to path
'/data/3/peel/flink/tmp/flink-io-3a97d62c-ada4-44f1-ab72-dd018386f9aa/79305169d69f7e8b361a175af87353fa.channel'
could not be opened.	at org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel.(AbstractFileIOChannel.java:61)	at org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel.(AsynchronousFileIOChannel.java:86)	at org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileWriter.(AsynchronousBufferFileWriter.java:31)	at org.apache.flink.runtime.io.disk.iomanager.IOManagerAsync.createBufferFileWriter(IOManagerAsync.java:257)	at org.apache.flink.runtime.io.network.partition.SpillableSubpartition.releaseMemory(SpillableSubpartition.java:151)	at org.apache.flink.runtime.io.network.partition.ResultPartition.releaseMemory(ResultPartition.java:366)	at org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestBuffer(LocalBufferPool.java:159)	at org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestBufferBlocking(LocalBufferPool.java:133)	at org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:92)	at org.apache.flink.runtime.operators.shipping.OutputCollector.collect(OutputCollector.java:65)	at org.apache.flink.runtime.operators.chaining.ChainedMapDriver.collect(ChainedMapDriver.java:78)	at org.apache.flink.runtime.operators.MapDriver.run(MapDriver.java:97)	at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:480)	at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:345)	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)	at java.lang.Thread.run(Thread.java:745)