банка, содержащая код работы моего Flink Job-Manager, но прежде чем задача-менеджер сможет выполнить код, управляющий Job-Manager не удается с приведенной ниже ошибкой: < /p>
Код: Выделить всё
2025-02-10 12:47:18,738 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: source-kafka-inventory-data -> inventory-shutdown-jvm-processor -> map-to-InventoryDataDbObjects -> process-custom-window-inventory-aggregator -> filter-aggregatedInventoryData-nonEmpty -> sink-flatmap-elastic-inventory-indices (1/1) (dd5610af487f8444ed47e3dc2385057c_c91ad22ec76be35fc44eb15e8f90515b_0_39) switched from INITIALIZING to FAILED on 10.42.0.60:6122-8e95cf @ 10-42-0-60.taskmanager.flink-gold-0001.svc.cluster.local (dataPort=6121).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:416) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:869) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:836) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:732) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:825) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:732) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:825) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:732) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:825) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:732) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:202) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.(RegularOperatorChain.java:60) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:789) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:771) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:939) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.0.jar:1.20.0]
at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.io.InvalidObjectException: ReflectiveOperationException during deserialization
at java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:280) ~[?:?]
at jdk.internal.reflect.GeneratedMethodAccessor13.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:569) ~[?:?]
at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1190) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2266) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:509) ~[?:?]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:467) ~[?:?]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:533) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:521) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:475) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:400) ~[flink-dist-1.20.0.jar:1.20.0]
... 18 more
Caused by: java.lang.reflect.InvocationTargetException
at jdk.internal.reflect.GeneratedMethodAccessor51.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:569) ~[?:?]
at java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:278) ~[?:?]
at jdk.internal.reflect.GeneratedMethodAccessor13.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:569) ~[?:?]
at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1190) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2266) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:509) ~[?:?]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:467) ~[?:?]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:533) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:521) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:475) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:400) ~[flink-dist-1.20.0.jar:1.20.0]
... 18 more
Caused by: java.lang.IllegalArgumentException: too many arguments
at java.lang.invoke.LambdaMetafactory.altMetafactory(LambdaMetafactory.java:511) ~[?:?]
at scala.runtime.LambdaDeserializer$.makeCallSite$1(LambdaDeserializer.scala:93) ~[flink-scala_2.12-1.20.0.jar:1.20.0]
at scala.runtime.LambdaDeserializer$.deserializeLambda(LambdaDeserializer.scala:102) ~[flink-scala_2.12-1.20.0.jar:1.20.0]
at scala.runtime.LambdaDeserialize.deserializeLambda(LambdaDeserialize.java:26) ~[flink-scala_2.12-1.20.0.jar:1.20.0]
at com.my.project.SourceSinkJob.$deserializeLambda$(SourceSinkJob.scala) ~[?:?]
at jdk.internal.reflect.GeneratedMethodAccessor51.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:569) ~[?:?]
at java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:278) ~[?:?]
at jdk.internal.reflect.GeneratedMethodAccessor13.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:569) ~[?:?]
at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1190) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2266) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream$FieldValues.(ObjectInputStream.java:2606) ~[?:?]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2457) ~[?:?]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2257) ~[?:?]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1733) ~[?:?]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:509) ~[?:?]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:467) ~[?:?]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:533) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:521) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:475) ~[flink-dist-1.20.0.jar:1.20.0]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:400) ~[flink-dist-1.20.0.jar:1.20.0]
... 18 more
2025-02-10 12:47:18,741 INFO org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager - Clearing resource requirements of job e269e79805b24a657bef56731c49db73
Подробнее здесь: https://stackoverflow.com/questions/794 ... 16-to-1-20
