报错信息看下:Caused by:
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException:
java.lang.NumberFormatException: Not a version: 9。



bigdata <1194803...@qq.com> 于2020年12月24日周四 下午9:49写道:

> flink1.10.1集群dml报错如下
> org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
> instantiate user function.
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:269)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.<init&gt;(OperatorChain.java:115)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:432)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:460)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
> &nbsp;&nbsp;&nbsp;&nbsp;at java.lang.Thread.run(Thread.java:745)
> Caused by:
> org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException:
> java.lang.NumberFormatException: Not a version: 9
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.api.scala.typeutils.TraversableSerializer$.compileCbf(TraversableSerializer.scala:184)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.api.scala.typeutils.TraversableSerializer.compileCbf(TraversableSerializer.scala:51)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> org.apache.flink.api.scala.typeutils.TraversableSerializer.readObject(TraversableSerializer.scala:72)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> &nbsp;&nbsp;&nbsp;&nbsp;at java.lang.reflect.Method.invoke(Method.java:498)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1058)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1900)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
> &nbsp;&nbsp;&nbsp;&nbsp;at
> java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000

回复