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

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

Hey Alex,

Try adding the following import:

import org.apache.flink.streaming.api.scala._

This adds all the implcit utilities that Flink needs to determine type info.

Best,

Marton

On Mon, Dec 7, 2015 at 10:24 AM, lofifnc <[hidden email]> wrote:

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



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-when-using-scala-api-fromElements-fromCollection-tp3938.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.