org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Job execution failed.

flink-user | ANDREA SPINA | 5 months ago
  1. 0

    Flink java.io.FileNotFoundException Exception with Peel Framework

    flink-user | 5 months ago | ANDREA SPINA
    org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Job execution failed.
  2. 0

    Error due to Hadoop version mismatch

    flink-dev | 12 months ago | Kashmar, Ali
    java.lang.Exception: Call to registerInputOutput() of invokable failed
  3. 0

    Re: Error due to Hadoop version mismatch

    flink-dev | 12 months ago | Robert Metzger
    java.lang.Exception: Call to registerInputOutput() of invokable failed
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Re: Error due to Hadoop version mismatch

    flink-dev | 12 months ago | Kashmar, Ali
    java.lang.Exception: Call to registerInputOutput() of invokable failed
  6. 0

    ftpsshproxy producing java.io.IOException: channel not open - Dovetailed Technologies

    dovetail.com | 4 months ago
    java.io.IOException: channel is not opened.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. 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.<init>()
    2. flink-runtime
      IOManagerAsync.createBufferFileWriter
      1. org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel.<init>(AbstractFileIOChannel.java:61)
      2. org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel.<init>(AsynchronousFileIOChannel.java:86)
      3. org.apache.flink.runtime.io.disk.iomanager.AsynchronousBufferFileWriter.<init>(AsynchronousBufferFileWriter.java:31)
      4. org.apache.flink.runtime.io.disk.iomanager.IOManagerAsync.createBufferFileWriter(IOManagerAsync.java:257)
      4 frames
    3. org.apache.flink
      RecordWriter.emit
      1. org.apache.flink.runtime.io.network.partition.SpillableSubpartition.releaseMemory(SpillableSubpartition.java:151)
      2. org.apache.flink.runtime.io.network.partition.ResultPartition.releaseMemory(ResultPartition.java:366)
      3. org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestBuffer(LocalBufferPool.java:159)
      4. org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestBufferBlocking(LocalBufferPool.java:133)
      5. org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:92)
      5 frames
    4. flink-runtime
      Task.run
      1. org.apache.flink.runtime.operators.shipping.OutputCollector.collect(OutputCollector.java:65)
      2. org.apache.flink.runtime.operators.chaining.ChainedMapDriver.collect(ChainedMapDriver.java:78)
      3. org.apache.flink.runtime.operators.MapDriver.run(MapDriver.java:97)
      4. org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:480)
      5. org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:345)
      6. org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
      6 frames
    5. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame