Could you check the definition of the collect method in the DataSet.scala file? Does it contain parentheses or not?
On Tue, Apr 14, 2015 at 3:48 PM, Felix Neutatz <neut...@googlemail.com> wrote: > I use the latest maven snapshot: > > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-scala</artifactId> > <version>0.9-SNAPSHOT</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-clients</artifactId> > <version>0.9-SNAPSHOT</version> > </dependency> > > > 2015-04-14 15:45 GMT+02:00 Robert Metzger <rmetz...@apache.org>: > > > Hi, > > > > which version of Flink are you using? > > > > On Tue, Apr 14, 2015 at 3:36 PM, Felix Neutatz <neut...@googlemail.com> > > wrote: > > > > > Hi, > > > > > > I want to run the following example: > > > > > > import org.apache.flink.api.scala._ > > > > > > case class EdgeType(src: Int, target: Int) > > > > > > object Test { > > > def main(args: Array[String]) { > > > implicit val env = ExecutionEnvironment.getExecutionEnvironment > > > > > > val graphEdges = readEdges("edges.csv") > > > > > > graphEdges.collect() > > > } > > > def readEdges(file: String)(implicit env: ExecutionEnvironment) = { > > > env.readCsvFile[EdgeType](file, "\n", "\t") > > > } > > > } > > > > > > But IntelliJ doesn't compile it and gives me the following explanation: > > > > > > > > > Error:(31, 21) not enough arguments for method apply: (n: Int)EdgeType > > > in trait BufferLike. > > > Unspecified value parameter n. > > > graphEdges.collect() > > > ^ > > > > > > Can anyone help me out here? > > > > > > Thanks, > > > > > > Felix > > > > > >