You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Robert Metzger <rm...@apache.org> on 2015/06/01 21:36:54 UTC
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
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 <sa...@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.
>
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Stephan Ewen <se...@apache.org>.
I agree, this would be nice to support in Flink.
The important parts are on the client side (which may be embedded). The
classloaders are used there as part of the de-serialization of messages
that contain user-defined types (such as in collect() or in accumulators
and in exception reporting).
How are you starting the program in your web-app, by the way?
If you would be up for contributing this fix, that would be great! One
could approach this in two ways:
- Simple, but not sure if completely future proof: we take always the
context classloader as the parent, and if that is null, the system class
loader
- More elaborate: We allow to set a root classloader on the
ExecutionEnvironment. That one should be passed as parent class loader to
the Remote Executor and the Client.
Greetings,
Stephan
On Mon, Dec 21, 2015 at 4:41 PM, peterpanne <er...@peukert.org> wrote:
> I identified the root-cause of the problem:
>
> When the FlinkUserCodeClassLoader ist created it simply instantiates the
> URLClassLoader which takes the System-Classloader as parent. However in the
> web-application-setting the current thread-webapp-classloader should be
> taken. I tried to change the class slightly to take the "right" threads
> class loader as parent.
> private static class FlinkUserCodeClassLoader extends URLClassLoader {
> public FlinkUserCodeClassLoader(URL[] urls) {
> super(urls,
> Thread.currentThread().getContextClassLoader());}}
>
> Unfortunately there are multiple places where the system-classloader ist
> taken instead of the thread class loader:
>
> flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
> That solved my problem for the moment.
> However, I am not sure if that introduces problems somewhere else. In
> theory
> it should not be critical since the web-appclassloader simply introduces an
> additional level of classes to look for.
>
> It would cool if that problem could be resolved in flink ;-)
>
>
>
>
>
> --
> 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-tp5922p9653.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
Re: ClassNotFoundException :
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while
trying to run locally
Posted by peterpanne <er...@peukert.org>.
I identified the root-cause of the problem:
When the FlinkUserCodeClassLoader ist created it simply instantiates the
URLClassLoader which takes the System-Classloader as parent. However in the
web-application-setting the current thread-webapp-classloader should be
taken. I tried to change the class slightly to take the "right" threads
class loader as parent.
private static class FlinkUserCodeClassLoader extends URLClassLoader {
public FlinkUserCodeClassLoader(URL[] urls) {
super(urls,
Thread.currentThread().getContextClassLoader());}}
Unfortunately there are multiple places where the system-classloader ist
taken instead of the thread class loader:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
That solved my problem for the moment.
However, I am not sure if that introduces problems somewhere else. In theory
it should not be critical since the web-appclassloader simply introduces an
additional level of classes to look for.
It would cool if that problem could be resolved in flink ;-)
--
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-tp5922p9653.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
Re: ClassNotFoundException :
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while
trying to run locally
Posted by peterpanne <er...@peukert.org>.
I am facing the same issue in a different setting:
I have a webapplication that calls the local flink execution.
Unfortunately the change in the bootloader chain introduces the described
problem
Boot classloader
App class-loader
webapp classloader (knows the flink-classes)
it seems that the InstantiationUtil from flink replaces the current context
class loader which knows about the flink classes with the blob-classloader
with does not have the webappclassloader as parent:
Boot classloader
App classloader
Flink's Blob classloader
This is obviously the same problem that also appears when running the local
flink election from within an eclipse plugin.
Could you help me here? What should I do to tell flink not to ignore the
webapp-classloader?
Best,
eric
--
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-tp5922p9649.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Stephan Ewen <se...@apache.org>.
Effectively, the method with the blob-classloader / parent classloader is
exactly intended to do that: Start with the app class path and add some
jars in addition, if you need to.
On Mon, Sep 7, 2015 at 1:05 PM, Stephan Ewen <se...@apache.org> wrote:
> The BlobClassloader uses the App classloader as the parent. That should
> make the classloading go first to the app classpath (TaskManager's
> classpath) and then to the user-defined code.
> Is that broken somehow?
>
>
>
> On Sun, Sep 6, 2015 at 1:40 PM, gkrastev <jo...@gmail.com> wrote:
>
>> Hi,I'm facing the exact same issue when running a custom Flink
>> interpreter in
>> Zeppelin, so it's a case of special classloader. I'm adding the Flink jars
>> to the Scala REPL's classpath manually, so I end up with the following
>> classloader chain:1. Boot classloader2. App classloader3. Scala
>> classloader
>> -> has Flink on the classpath4. Translating classloader for the Scala
>> REPLSo
>> the class is accessible in the vanilla Zeppelin shell. E.g. the following
>> code works fine:
>>
>> println(classOf[org.apache.flink.api.common.operators.util.UserCodeObjectWrapper[String]])
>> However, the classloader chain in the Task Manager looks differently:1.
>> Boot
>> classloader2. App classloader3. Flink's Blob classloaderAnd the following
>> code fails:
>> import org.apache.flink.api.scala._env.fromCollection(1 to 100).reduce {
>> _ +
>> _ }.collect()
>> because the Flink jars are no longer on the classpath. The question is,
>> why
>> doesn't Flink pickup the current classloader/classpath when starting Task
>> Managers, and can I add entries to their classpath manually?
>> Robert Metzger wrote
>> > Can you give us some context what you are trying to do?It sounds a lot
>> > like you would like to develop a Flink Plugin for Eclipse?And that
>> plugin
>> > needs Flink dependencies?Sorry for asking so many questions, but the
>> issue
>> > you are facing sounds alot like a) a very special classloader or b)
>> > corrupt files.I think some more info on what you are doing might help us
>> > to understandthe issue to give you better help.
>>
>>
>>
>>
>>
>> --
>> 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-tp5922p7870.html
>> Sent from the Apache Flink Mailing List archive. mailing list archive at
>> Nabble.com.
>>
>
>
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Stephan Ewen <se...@apache.org>.
The BlobClassloader uses the App classloader as the parent. That should
make the classloading go first to the app classpath (TaskManager's
classpath) and then to the user-defined code.
Is that broken somehow?
On Sun, Sep 6, 2015 at 1:40 PM, gkrastev <jo...@gmail.com> wrote:
> Hi,I'm facing the exact same issue when running a custom Flink interpreter
> in
> Zeppelin, so it's a case of special classloader. I'm adding the Flink jars
> to the Scala REPL's classpath manually, so I end up with the following
> classloader chain:1. Boot classloader2. App classloader3. Scala classloader
> -> has Flink on the classpath4. Translating classloader for the Scala
> REPLSo
> the class is accessible in the vanilla Zeppelin shell. E.g. the following
> code works fine:
>
> println(classOf[org.apache.flink.api.common.operators.util.UserCodeObjectWrapper[String]])
> However, the classloader chain in the Task Manager looks differently:1.
> Boot
> classloader2. App classloader3. Flink's Blob classloaderAnd the following
> code fails:
> import org.apache.flink.api.scala._env.fromCollection(1 to 100).reduce { _
> +
> _ }.collect()
> because the Flink jars are no longer on the classpath. The question is, why
> doesn't Flink pickup the current classloader/classpath when starting Task
> Managers, and can I add entries to their classpath manually?
> Robert Metzger wrote
> > Can you give us some context what you are trying to do?It sounds a lot
> > like you would like to develop a Flink Plugin for Eclipse?And that plugin
> > needs Flink dependencies?Sorry for asking so many questions, but the
> issue
> > you are facing sounds alot like a) a very special classloader or b)
> > corrupt files.I think some more info on what you are doing might help us
> > to understandthe issue to give you better help.
>
>
>
>
>
> --
> 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-tp5922p7870.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
Re: ClassNotFoundException :
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while
trying to run locally
Posted by gkrastev <jo...@gmail.com>.
Hi,I'm facing the exact same issue when running a custom Flink interpreter in
Zeppelin, so it's a case of special classloader. I'm adding the Flink jars
to the Scala REPL's classpath manually, so I end up with the following
classloader chain:1. Boot classloader2. App classloader3. Scala classloader
-> has Flink on the classpath4. Translating classloader for the Scala REPLSo
the class is accessible in the vanilla Zeppelin shell. E.g. the following
code works fine:
println(classOf[org.apache.flink.api.common.operators.util.UserCodeObjectWrapper[String]])
However, the classloader chain in the Task Manager looks differently:1. Boot
classloader2. App classloader3. Flink's Blob classloaderAnd the following
code fails:
import org.apache.flink.api.scala._env.fromCollection(1 to 100).reduce { _ +
_ }.collect()
because the Flink jars are no longer on the classpath. The question is, why
doesn't Flink pickup the current classloader/classpath when starting Task
Managers, and can I add entries to their classpath manually?
Robert Metzger wrote
> Can you give us some context what you are trying to do?It sounds a lot
> like you would like to develop a Flink Plugin for Eclipse?And that plugin
> needs Flink dependencies?Sorry for asking so many questions, but the issue
> you are facing sounds alot like a) a very special classloader or b)
> corrupt files.I think some more info on what you are doing might help us
> to understandthe issue to give you better help.
--
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-tp5922p7870.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Robert Metzger <rm...@apache.org>.
Can you give us some context what you are trying to do?
It sounds a lot like you would like to develop a Flink Plugin for Eclipse?
And that plugin needs Flink dependencies?
Sorry for asking so many questions, but the issue you are facing sounds a
lot like a) a very special classloader or b) corrupt files.
I think some more info on what you are doing might help us to understand
the issue to give you better help.
On Thu, Jun 4, 2015 at 4:52 PM, santosh_rajaguru <sa...@gmail.com> wrote:
> I am using eclipse kepler
> I tried to replicate the same problem in another workspace.
> When i try to test the plugin using Junit PlugIn Test it throws me the
> classNotFoundException.
> However, when i try to test it as JunitTest,it works fine.
> Am i missing something here?
>
>
>
>
>
> --
> 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-tp5922p6143.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
Re: ClassNotFoundException :
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while
trying to run locally
Posted by santosh_rajaguru <sa...@gmail.com>.
I am using eclipse kepler
I tried to replicate the same problem in another workspace.
When i try to test the plugin using Junit PlugIn Test it throws me the
classNotFoundException.
However, when i try to test it as JunitTest,it works fine.
Am i missing something here?
--
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-tp5922p6143.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Stephan Ewen <se...@apache.org>.
What IDE are you using, that you have to refer to the dependencies as
plugins?
On Wed, Jun 3, 2015 at 11:25 PM, santosh_rajaguru <sa...@gmail.com> wrote:
> sorry for the mistake. that is referred to plugin development.
> So i had to manage the flink dependencies as plugins to make it work.
> but due to some reason it cannot find that particular class.
>
>
>
> --
> 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-tp5922p6087.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
Re: ClassNotFoundException :
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while
trying to run locally
Posted by santosh_rajaguru <sa...@gmail.com>.
sorry for the mistake. that is referred to plugin development.
So i had to manage the flink dependencies as plugins to make it work.
but due to some reason it cannot find that particular class.
--
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-tp5922p6087.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Stephan Ewen <se...@apache.org>.
Can you tell us what you mean with "Plugin environment" ?
On Tue, Jun 2, 2015 at 9:38 PM, santosh_rajaguru <sa...@gmail.com> wrote:
> Thanks Robert and Stephan.
>
> I executed the program in maven environment. It works fine.
> However, in Plugin environment, though i have included all the dependencies
> and dependent jars, it says classnotfoundexception while executing the env.
>
>
>
>
>
> --
> 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-tp5922p5997.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
Re: ClassNotFoundException :
org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while
trying to run locally
Posted by santosh_rajaguru <sa...@gmail.com>.
Thanks Robert and Stephan.
I executed the program in maven environment. It works fine.
However, in Plugin environment, though i have included all the dependencies
and dependent jars, it says classnotfoundexception while executing the env.
--
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-tp5922p5997.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
while trying to run locally
Posted by Stephan Ewen <se...@apache.org>.
The stack trace looks really like the class "UserCodeObjectWrapper" was not
found.
That is a core Flink runtime class and the fact that it is missing
indicates that there is something inconsistent with your libraries. Either
some JAR files are missing or damaged.
Did you use a downloaded binary distribution, or did you build it yourself?
If you built it yourself, can you rebuild it and see if there was just some
some transient error in maven, or whether this is reproducible?
On Mon, Jun 1, 2015 at 9:36 PM, Robert Metzger <rm...@apache.org> wrote:
> 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 <sa...@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.
> >
>