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 <rmetz...@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 <sani...@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. > > >
