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