Mailing-List: contact dev-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <1433026026576-5922.post@n3.nabble.com>
References: <1433026026576-5922.post@n3.nabble.com>
From: Robert Metzger <rmetzger@apache.org>
Date: Mon, 1 Jun 2015 21:36:54 +0200
Message-ID: 
 <CAGr9p8B5vqBAtuB2h92T36uc3vb_HSfL3gzHMSxgi5oig7oa3g@mail.gmail.com>
Subject: Re: ClassNotFoundException :
 org.apache.flink.api.common.operators.util.UserCodeObjectWrapper,
 while trying to run locally
To: "dev@flink.apache.org" <dev@flink.apache.org>
Content-Type: multipart/alternative; boundary=047d7b5d86a5ed224b051779f3e0

--047d7b5d86a5ed224b051779f3e0
Content-Type: text/plain; charset=UTF-8

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.
>

--047d7b5d86a5ed224b051779f3e0--