Replies: 1 comment
-
我也遇到这个问题,有解决的吗 |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
flink:1.13.1
streamPark:2.0.0
jdk:1.8
scala:2.11
运行streamPark提供的Flink Demo 报错
java.util.concurrent.CompletionException: java.lang.reflect.InvocationTargetException at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.streampark.flink.client.FlinkClient$$anonfun$proxy$1.apply(FlinkClient.scala:68) at org.apache.streampark.flink.client.FlinkClient$$anonfun$proxy$1.apply(FlinkClient.scala:63) at org.apache.streampark.flink.proxy.FlinkShimsProxy$$anonfun$proxy$1.apply(FlinkShimsProxy.scala:63) at org.apache.streampark.common.util.ClassLoaderUtils$.runAsClassLoader(ClassLoaderUtils.scala:40) at org.apache.streampark.flink.proxy.FlinkShimsProxy$.proxy(FlinkShimsProxy.scala:63) at org.apache.streampark.flink.client.FlinkClient$.proxy(FlinkClient.scala:63) at org.apache.streampark.flink.client.FlinkClient$.submit(FlinkClient.scala:43) at org.apache.streampark.flink.client.FlinkClient.submit(FlinkClient.scala) at org.apache.streampark.console.core.service.impl.ApplicationServiceImpl.lambda$start$10(ApplicationServiceImpl.java:1543) at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ... 3 more Caused by: java.lang.ClassCastException: org.apache.streampark.flink.packer.pipeline.SimpleBuildResponse cannot be cast to org.apache.streampark.flink.packer.pipeline.ShadedBuildResponse at org.apache.streampark.flink.client.bean.SubmitRequest.userJarFile$lzycompute(SubmitRequest.scala:87) at org.apache.streampark.flink.client.bean.SubmitRequest.userJarFile(SubmitRequest.scala:82) at org.apache.streampark.flink.client.trait.FlinkClientTrait$class.submit(FlinkClientTrait.scala:83) at org.apache.streampark.flink.client.impl.RemoteClient$.submit(RemoteClient.scala:38) at org.apache.streampark.flink.client.FlinkClientHandler$.submit(FlinkClientHandler.scala:40) at org.apache.streampark.flink.client.FlinkClientHandler.submit(FlinkClientHandler.scala) ... 17 more
Beta Was this translation helpful? Give feedback.
All reactions