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