flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally
Date Mon, 01 Jun 2015 19:36:54 GMT
Hi Santosh,

sorry for the late reply.
I'm not 100% sure whats causing the issue. I'm not sure if the
ThreadPoolExecutor (which seems to start a Flink LocalExecutor in the
worker threads) is causing some issues.
Are the executors starting local Flink instances in parallel?

The last "Caused By" says: "java.lang.ClassNotFoundException:
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper", but I
doubt it was unable to find that class. Are you sure that you've copied the
entire stacktrace?
Maybe the thread pool is also cutting away the root cause?
Sorry, that I have to guess here, but I can not see an obvious reason for
this to fail.

If possible, can you share the code with us? Maybe that will also help us
to understand the issue.

Best,
Robert


On Sun, May 31, 2015 at 12:47 AM, santosh_rajaguru <sanit4u@gmail.com>
wrote:

> Hi,
>
> I am trying to execute a flatmapFunction for a xmlString(byte array) using
> plugin development.
> I have added the required dependencies for flink.
> I am using Flink-0.8.1.
>
> The stack trace of the execution is as follows:
>
> org.apache.flink.runtime.client.JobExecutionException: java.lang.Exception:
> Deserializing the OutputFormat (Print to System.out) failed: Could not read
> the user code wrapper:
> org.apache.flink.api.common.operators.util.UserCodeObjectWrapper
>         at
>
> org.apache.flink.runtime.jobgraph.OutputFormatVertex.initializeOnMaster(OutputFormatVertex.java:63)
>         at
>
> org.apache.flink.runtime.jobmanager.JobManager.submitJob(JobManager.java:385)
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at
>
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>         at
>
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>         at java.lang.reflect.Method.invoke(Method.java:606)
>         at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
>         at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
> Caused by:
> org.apache.flink.runtime.operators.util.CorruptConfigurationException:
> Could
> not read the user code wrapper:
> org.apache.flink.api.common.operators.util.UserCodeObjectWrapper
>         at
>
> org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:283)
>         at
>
> org.apache.flink.runtime.jobgraph.OutputFormatVertex.initializeOnMaster(OutputFormatVertex.java:60)
>         ... 7 more
> Caused by: java.lang.ClassNotFoundException:
> org.apache.flink.api.common.operators.util.UserCodeObjectWrapper
>         at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
>         at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
>         at java.security.AccessController.doPrivileged(Native Method)
>         at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
>         at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
>         at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
>         at java.lang.Class.forName0(Native Method)
>         at java.lang.Class.forName(Class.java:270)
>         at
>
> org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:54)
>         at
> java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1612)
>         at
> java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517)
>         at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1771)
>         at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
>         at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
>         at
>
> org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:274)
>         at
>
> org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:236)
>         at
>
> org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:281)
>         ... 8 more
>
>         at
>
> org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:256)
>         at
> org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:239)
>         at
>
> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:51)
>         at
>
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:683)
>         at
>
> de.fraunhofer.fokus.odp.harvester.ieee.IEEEHarvester.processMapRDf(IEEEHarvester.java:183)
>         at
>
> de.fraunhofer.fokus.odp.harvester.ieee.IEEEHarvester.harvest(IEEEHarvester.java:127)
>         at
> de.fraunhofer.fokus.odp.harvester.Harvester.call(Harvester.java:164)
>         at
> de.fraunhofer.fokus.odp.harvester.Harvester.call(Harvester.java:1)
>         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)
>
>
> i have been working and digging the stuff for solution.
> i will appreciate a help in any manner.
>
> Thanks,
> Santosh
>
>
>
> --
> View this message in context:
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ClassNotFoundException-org-apache-flink-api-common-operators-util-UserCodeObjectWrapper-while-tryingy-tp5922.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message