无法从 JAR 文件构建程序

Question

我Flink在本地集群上运行，编译我运行的包后

flink run -c com.gurustreams.flink.EntryPoint \
    /Users/jeremy.zhang/workspace/guru-streams/flink/target/scala-2.11/guru-streams-flink-assembly-0.0.1.jar \
    --stream-name KafkaReadExample

并收到此错误：

Could not build the program from JAR file.

我还尝试jar从Flink仪表板运行文件并出现此错误：

org.apache.flink.client.program.ProgramInvocationException: The program plan could not be fetched - the program aborted pre-maturely.

System.err: (none)

System.out: (none)

Answer 1

如果在打包 JAR 文件以及从 CLASSPATH 需要的其他内容的过程中抛出 FileNotFoundException 异常，Flink CLI 会显示“无法从 JAR 文件构建程序”。某处似乎配置错​​误。

如果您查看日志，您应该会找到更多信息来帮助调试。

通常，日志将位于集群的每个节点上的 flink 安装的日志目录中。您可以使用 Flink 仪表板检查它们。对于本地集群，可以在http://localhost:8081/#/jobmanager/log 查看 jobmanager 日志。对于任务管理器，转到http://localhost:8081/#/taskmanagers，选择一个任务管理器，然后单击 Logs。

当出现问题时，查看 jobmanager 和 taskmanager 日志以获取线索会很有帮助。