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

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

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
Reply | Threaded
Open this post in threaded view
|

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

Stephan Ewen

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.

Reply | Threaded
Open this post in threaded view
|

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

Márton Balassi
In reply to this post by lofifnc
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.

Reply | Threaded
Open this post in threaded view
|

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

lofifnc
This post was updated on .
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!