You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Flavio Pompermaier <po...@okkam.it> on 2017/09/14 16:56:00 UTC
Eception while running Table API job
Hi to all,
I've tested my Flink 1.3.1 on my local machine and everything was fine.
So I've tried to run it on the cluster but I've got the following weird
exception (I've already moved flink-table_2.10-1.3.1.jar from opt to lib):
Caused by: java.lang.RuntimeException: The initialization of the
DataSource's outputs caused an error: Could not read the user code wrapper:
org.apache.flink.table.runtime.FlatMapRunner
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:94)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702)
at java.lang.Thread.run(Thread.java:745)
Caused by:
org.apache.flink.runtime.operators.util.CorruptConfigurationException:
Could not read the user code wrapper:
org.apache.flink.table.runtime.FlatMapRunner
at
org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:290)
at
org.apache.flink.runtime.operators.BatchTask.instantiateUserCode(BatchTask.java:1432)
at
org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.setup(ChainedFlatMapDriver.java:39)
at
org.apache.flink.runtime.operators.chaining.ChainedDriver.setup(ChainedDriver.java:90)
at
org.apache.flink.runtime.operators.BatchTask.initOutputs(BatchTask.java:1299)
at
org.apache.flink.runtime.operators.DataSourceTask.initOutputs(DataSourceTask.java:287)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:91)
... 2 more
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.table.runtime.FlatMapRunner
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at
org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:64)
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613)
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:290)
at
org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:248)
at
org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:288)
... 8 more
What should I do?
Best,
Flavio
Re: Eception while running Table API job
Posted by Flavio Pompermaier <po...@okkam.it>.
Sorry..the error was caused by the fact that I've moved the table jar only
on the job manager machine.
After copying the jar from opt to lib in all the other TM machines the job
was able to continue!
Best,
Flavio
On Thu, Sep 14, 2017 at 6:56 PM, Flavio Pompermaier <po...@okkam.it>
wrote:
> Hi to all,
> I've tested my Flink 1.3.1 on my local machine and everything was fine.
> So I've tried to run it on the cluster but I've got the following weird
> exception (I've already moved flink-table_2.10-1.3.1.jar from opt to lib):
>
>
> Caused by: java.lang.RuntimeException: The initialization of the
> DataSource's outputs caused an error: Could not read the user code wrapper:
> org.apache.flink.table.runtime.FlatMapRunner
> at org.apache.flink.runtime.operators.DataSourceTask.
> invoke(DataSourceTask.java:94)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.apache.flink.runtime.operators.util.CorruptConfigurationException:
> Could not read the user code wrapper: org.apache.flink.table.
> runtime.FlatMapRunner
> at org.apache.flink.runtime.operators.util.TaskConfig.
> getStubWrapper(TaskConfig.java:290)
> at org.apache.flink.runtime.operators.BatchTask.
> instantiateUserCode(BatchTask.java:1432)
> at org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.setup(
> ChainedFlatMapDriver.java:39)
> at org.apache.flink.runtime.operators.chaining.ChainedDriver.setup(
> ChainedDriver.java:90)
> at org.apache.flink.runtime.operators.BatchTask.
> initOutputs(BatchTask.java:1299)
> at org.apache.flink.runtime.operators.DataSourceTask.
> initOutputs(DataSourceTask.java:287)
> at org.apache.flink.runtime.operators.DataSourceTask.
> invoke(DataSourceTask.java:91)
> ... 2 more
> Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.
> runtime.FlatMapRunner
> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> at java.lang.Class.forName0(Native Method)
> at java.lang.Class.forName(Class.java:348)
> at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.
> resolveClass(InstantiationUtil.java:64)
> at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613)
> at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518)
> at java.io.ObjectInputStream.readOrdinaryObject(
> ObjectInputStream.java:1774)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
> at java.io.ObjectInputStream.defaultReadFields(
> ObjectInputStream.java:2000)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
> at java.io.ObjectInputStream.readOrdinaryObject(
> ObjectInputStream.java:1801)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
> at org.apache.flink.util.InstantiationUtil.deserializeObject(
> InstantiationUtil.java:290)
> at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(
> InstantiationUtil.java:248)
> at org.apache.flink.runtime.operators.util.TaskConfig.
> getStubWrapper(TaskConfig.java:288)
> ... 8 more
>
> What should I do?
>
> Best,
> Flavio
>