基于上一步的代码和POM，flink1.8.0， scala 2.11.12
本地运行代码一直可以（pom中flink相关依赖的scope修改为compile）
打成jar包提交到本地local模式集群上运行一直报错，如下：
org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result
最终重启电脑解决。
flink运行报错 org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。
猜您在找
Flink 报错 "Could not find a suitable table factory for 'org.apache.flink.table.factories.StreamTableSourceFactory' in the classpath"
flink run 报错Could not build the program from JAR file.
flink run 报错java.lang.NoSuchMethodError: org.apache.hadoop.ipc.Client.getRpcTimeout(Lorg/apache/hadoop/conf/Configuration;)I
flink-sql-gateway:Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.CatalogFactory' in the classpath.
idea中flink启动报错org.apache.flink.api.common.ExecutionConfig$GlobalJobParameters
flink程序报错ClassNotFoundException: org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
apache flink kubernetes 运行试用
Flink- 本地运行报错（Cannot find compatible factory for specified execution.target (=local)）
Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath
Flink应用报错 Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.functions.FlatMapFunction