基於上一步的代碼和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