flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: Eception while running Table API job
Date Thu, 14 Sep 2017 17:06:02 GMT
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 <pompermaier@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
>

Mime
View raw message