Eception while running Table API job

[Flavio Pompermaier]

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

[Flavio Pompermaier]

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 <[hidden email]> 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