Apache flink快速入门K-Means的“分析结果”错误


0

我通过:quicku start跟踪了Apache flink的实现

我无法执行最后一个任务,即“分析结果”,因为kmeans文件夹中没有结果文件。

如果您查看上面flink JobManager的屏幕截图,您可以看到KMeans示例的状态为FAILED。可能是由于这种失败状态,kmeans文件夹中没有结果文件。

现在单击KMeans示例,我得到以下可视化效果:

以下是例外情况的截图:

你能告诉我我做错了什么吗。

1 答案


0

问题是,集群是用一个TaskManager启动的,这个TaskManager只有一个插槽,您希望同时以4的并行度执行KMeans job。

为了以4的并行度运行 job,必须增加集群中TaskManager的数量或每个TaskManager上的插槽数量。后者可以在Flink配置Flink中设置-形态亚马尔与taskmanager.numberOfTaskSlots任务管理器: 4. 对于前者,可以修改conf/slaves文件,为额外的TaskManager添加新的机器。

或者,可以将 job的并行性降低到1。您可以使用命令行选项-p来控制并行性,例如bin/flinkrun-p1-cjobClass job.tar.


我来回答

写文章

提问题

面试题