scala - 无法从 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.

我还尝试从 Flink 仪表板运行 jar 文件并出现以下错误:

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 ，选择一个任务管理器，然后单击“日志”。

当出现问题时，查看作业管理器和任务管理器日志以获取线索会很有帮助。