play.api.http.HttpErrorHandlerExceptions$$anon$1: Execution exception[[JobExecutionException: Cannot initialize task 'DataSink (collect())': Deserializing the OutputFormat (org.apache.flink.api.java.Utils$CollectHelper@1f158fd6) failed: Could not read the user code wrapper: io.fabrick.aperture.doctor.stream.WordCount$$anon$2$$anon$1]]

Stack Overflow | zaphod | 8 months ago
tip
Do you find the tips below useful? Click on the to mark them and say thanks to rafael . Or join the community to write better ones.
  1. 1

    Flink : WordCount example throws ClassNotFoundException

    Stack Overflow | 8 months ago | zaphod
    play.api.http.HttpErrorHandlerExceptions$$anon$1: Execution exception[[JobExecutionException: Cannot initialize task 'DataSink (collect())': Deserializing the OutputFormat (org.apache.flink.api.java.Utils$CollectHelper@1f158fd6) failed: Could not read the user code wrapper: io.fabrick.aperture.doctor.stream.WordCount$$anon$2$$anon$1]]
  2. 0

    Flink: DataSource's outputs caused an error: Could not read the user code wrapper

    Stack Overflow | 2 years ago | ashish
    java.lang.Exception: Call to registerInputOutput() of invokable failed
  3. 0

    java.lang.ClassNotFoundException when deploying streaming jar locally

    apache.org | 1 year ago
    org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    java.lang.ClassNotFoundException when deploying streaming jar locally

    flink-user | 2 years ago | Michael Huelfenhaus
    org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
  6. 0
    samebug tip
    This might be an issue with the file location in the Spark submit command. Try it with "spark-submit --master spark://master:7077 hello_world_from_pyspark.py {file location}"

  1. bandoca 2 times, last 3 days ago
  2. jokester 2 times, last 5 days ago
  3. arturgajowy 8 times, last 5 days ago
  4. rp 1 times, last 2 weeks ago
  5. tzrlk 1 times, last 4 weeks ago
64 more registered users
31 unregistered visitors
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.lang.ClassNotFoundException

    io.fabrick.aperture.doctor.stream.WordCount$$anon$2$$anon$1

    at java.net.URLClassLoader.findClass()
  2. Java RT
    Class.forName
    1. java.net.URLClassLoader.findClass(URLClassLoader.java:381)[na:1.8.0_60]
    2. java.lang.ClassLoader.loadClass(ClassLoader.java:424)[na:1.8.0_60]
    3. java.lang.ClassLoader.loadClass(ClassLoader.java:357)[na:1.8.0_60]
    4. java.lang.Class.forName0(Native Method)[na:1.8.0_60]
    5. java.lang.Class.forName(Class.java:348)[na:1.8.0_60]
    5 frames
  3. flink-core
    InstantiationUtil$ClassLoaderObjectInputStream.resolveClass
    1. org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:64)[flink-core-1.0.0.jar:1.0.0]
    1 frame
  4. Java RT
    ObjectInputStream.readObject0
    1. java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613)[na:1.8.0_60]
    2. java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518)[na:1.8.0_60]
    3. java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774)[na:1.8.0_60]
    4. java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)[na:1.8.0_60]
    4 frames