Hi, I'm running Flink 1.0.2 from the Zeppelin/shell- trying to experiment with some graph stuff.
Zeppelin has been known to add degrees of crazy to trouble shooting- but I intuitively feel like this is something I'm doing wrong on the Flink Side. The simplest example is not working for me. import org.apache.flink.api.scala._ import org.apache.flink.graph.Edge import org.apache.flink.graph.Vertex import org.apache.flink.graph.Graph 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(edges, vertices) Yields: <console>:46: error: type mismatch; found : Seq[org.apache.flink.graph.Edge[Long,String]] required: java.util.Collection[org.apache.flink.graph.Edge[?,?]] val graph = Graph.fromCollection(edges, vertices) I get a similar error when I try to make DataSets, found : org.apache.flink.api.scala.DataSet[org.apache.flink.graph.Edge[Long,Double]] required: org.apache.flink.api.java.DataSet[org.apache.flink.graph.Edge[?,?]] val graph = Graph.fromDataSet( edges, vertices) Thoughts? thanks, tg Trevor Grant Data Scientist https://github.com/rawkintrevo http://stackexchange.com/users/3002022/rawkintrevo http://trevorgrant.org *"Fortunate is he, who is able to know the causes of things." -Virgil*
