flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From santosh_rajaguru <sani...@gmail.com>
Subject ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally
Date Sat, 30 May 2015 22:47:06 GMT
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
View raw message