Apache快速启动“分析结果”错误的K-方法

Question

我通过：开始跟踪Apache-flink的实现。

我无法完成最后一项任务。“分析结果”，因为kmeans文件夹中没有结果文件。

​

​

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

现在，单击KMeans示例，我得到了以下可视化结果：

​

​

下面是例外情况的截图：

​

​

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

Answer 1

问题是集群是用一个只有一个插槽的TaskManager启动的，并且您希望同时执行KMeans作业，并行性为4。

为了运行并行性为4的作业，必须增加集群的TaskManager数量或每个TaskManager上的插槽数。后者可以在带有flink-conf.yaml的Flink配置taskmanager.numberOfTaskSlots: 4中设置。对于前者，可以修改conf/slaves文件以为附加的TaskManager添加新机器。

或者，您可以将作业的并行性减少到1，可以使用命令行选项-p来控制并行性。例如bin/flink run -p 1 -c JobClass job.tar。