Flink Gelly - Несоответствие типов при создании графика

Question

Я новичок в Apache Flink и Gelly, и я использую Scala API. У меня есть DataSet вершин и DataSet ребер, и я пытаюсь создать график следующим образом:

val env = ExecutionEnvironment.getExecutionEnvironment
// correct result
val edges: DataSet[Edge[Long, Long]] = (some transformations here)
//also correct result
val vertices: DataSet[Vertex[Long, String]] = (some transformations here)
//in the line below I get the errors
val graph = Graph.fromDataSet(vertices, edges, env)

И я получаю следующие ошибки:

Type mismatch,expected: 
  DataSet[Vertex[NotInferedK,NotInferedVV]], actual: DataSet[Vertex[Long,String]]

Type mismatch,expected: 
  DataSet[Edges[NotInferedK,NotInferedEV]], actual: DataSet[Edge[Long,Long]]

Type mismatch,expected: 
  org.apache.flink.api.java.ExecutionEnvironment, actual: org.apache.flink.api.scala.ExecutionEnvironment

Answer 1

Это выглядит так, как будто вы импортировали Graph из Java API Гелли. Попробуйте импортировать версию Scala Graph с помощью import org.apache.flink.graph.scala.Graph, Это должно исправить вашу проблему.