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