Я пытаюсь выполнить очень простой код для обнаружения сообщества, но она возвращает ошибку:несоответствие типов Flink граф сообщество
import org.apache.flink.graph.library.CommunityDetection
import org.apache.flink.graph._
import org.apache.flink.graph.scala.Graph
import java.lang.Long
import java.lang.Double
import org.apache.flink.api.scala._
val env = ExecutionEnvironment.getExecutionEnvironment
val vertices = Seq(new Vertex[Long, String](1L, "foo"), new Vertex[Long, String](2L, "bar"))
val edges = Seq(new Edge[Long, String](1L, 2L, "foobar"))
val graph = Graph.fromCollection(vertices, edges, env)
val updatedGraph = graph.mapVertices(v => v.getValue + 1)
val resultGraph = graph.run(new CommunityDetection[Long](30, 0.5))
^
Ошибка: (30, 33) несоответствие типа; найдено: org.apache.flink.graph.library.CommunityDetection [Long] required: org.apache.flink.graph.GraphAlgorithm [Long, String, String ,?] val resultGraph = graph.run (новый CommunityDetection [Long ] (30, 0.5)) –