Flink:连接的组件 - 类型不匹配错误

Question

我正在尝试使用 Scala API 在图形上运行连接组件算法，如编程指南和其他示例所示。

val graph = Graph.fromDataSet(vertices, edges, env).getUndirected
val maxIterations = 10
val components = graph.run(new ConnectedComponents(maxIterations))

我收到以下错误：

Type mismatch, expected: GraphAlgorithm[Long,String,Long,NotInferedT], actual: ConnectedComponents[Nothing,Nothing]

即使我添加

val components = graph.run(new ConnectedComponents[Long,String,Long](maxIterations))

我得到：

Type mismatch, expected: GraphAlgorithm[Long,String,Long,NotInferedT], actual: ConnectedComponents[Long,String]

我的进口是这些：

import org.apache.flink.api.scala._
import org.apache.flink.graph.library.ConnectedComponents
import org.apache.flink.graph.{Vertex, Edge}
import org.apache.flink.graph.scala.Graph

有人可以解释为什么会发生这种情况吗？

Answer 1

ConnectedComponents Gelly 库算法需要 2 个类型参数，顶点 ID 类型和边缘值类型，因此您需要像这样调用它，例如 graph.run(new ConnectedComponents[Long, NullValue](maxIterations) .另外，由于它是 Java 实现，请确保导入 java.lang.Long .您还可以查看使用 GSA 版本的库算法的org.apache.flink.graph.scala.example.ConnectedComponents。

Answer 2

问题是ConnectedComponents实现期望顶点具有java.lang.Long顶点值。不幸的是，scala.Long 和 java.lang.Long 与类型不兼容。因此，为了使用该算法，您的vertices数据集必须是DataSet[K, java.lang.Long]类型，K是任意键类型。

Answer 3

这

看起来像是典型的java/scala类型不匹配。请再次检查您使用的是java.lang.Long还是scala。在这种情况下很长。

Answer 4

vasia 和 Till Rohrmann 是对的，但就我而言，整个问题可以追溯到顶点和边的创建，而不仅仅是连接组件算法的使用。我正在使用 scala 创建顶点和边。长而不是java.lang.Long。