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 от API Java Gelly. Попробуйте импортировать версию Scala Graph, используя import org.apache.flink.graph.scala.Graph. Это должно решить вашу проблему.