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

[lofifnc]

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

[Stephan Ewen]

Have a look here: http://flink.apache.org/faq.html#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters

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.

... [show rest of quote]

[Márton Balassi]

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.

... [show rest of quote]

[lofifnc]

Thanks!

I should've mentioned that I've seen the FAQ but I didn't notice intellij deleting the import immediately.
For anyone encountering a similar behavior:
http://stackoverflow.com/questions/11154912/how-to-prevent-intellij-idea-from-deleting-unused-packages
Note that you have uncheck "optimize imports on the fly" for scala separately.

Best, Alex!