Error when using scala api .fromElements() / .fromCollection()

Posted by lofifnc on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Error-when-using-scala-api-fromElements-fromCollection-tp3938.html

Hi,

I'm getting an error when using .fromElements() of the StreamExecutionEnvironment or ExectutionEnvironment of the scala api:

Error:(53, 54) could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[Int]
    val source : DataSet[Int] = env.fromElements[Int](1, 2, 3, 4, 5)
                                                     ^
My code looks like this:
val env = ExecutionEnvironment.createLocalEnvironment(1)
val source : DataSet = env.fromElements(1, 2, 3, 4, 5)

I'm compiling with java 1.7 and using scala 2.10.4

Best, Alex