我在跑步 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
Jmeter 板并显示此错误:
org.apache.flink.client.program.ProgramInvocationException: The program plan could not be fetched - the program aborted pre-maturely.
System.err: (none)
System.out: (none)
2条答案
按热度按时间yx2lnoni1#
如果在打包jar文件的过程中抛出filenotfoundexception异常,flink cli会说“无法从jar文件构建程序”。似乎有什么地方配置错误。
如果您查看日志,您应该可以找到更多信息来帮助调试。
通常,日志将位于集群的每个节点上的flink安装的日志目录中。您可以使用flink Jmeter 板检查它们。对于本地集群,可以在以下位置查看jobmanager日志http://localhost:8081/#/作业管理器/日志。对于TaskManager,请转到http://localhost:8081/#/taskmanagers,选择一个taskmanager,然后单击logs。
当出现问题时,查看jobmanager和taskmanager日志寻找线索会很有帮助。
fzsnzjdm2#
这个异常的另一个简单但被忽略的可能性是磁盘空间不足,在一个小的vm上与flink进行了一点小冲突之后,这种情况很快就会发生。