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

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 wrote: > Hi, > > I'm getting an error when using .fromElements() of the > StreamExecutionEnvironment

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

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 wrote: > Hi, > > I'm getting an error when

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

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

Re: Using Flink with Scala 2.11 and Java 8

Hi Cory, Thanks for reporting the issue. Scala should run independently of the Java version. We are already using ASM version 5.0.4. However, some code uses the ASM4 op codes which don't seem to be work with Java 8. This needs to be fixed. I'm filing a JIRA. Cheers, Max On Mon, Dec 7, 2015 at

Re: Using Flink with Scala 2.11 and Java 8

Sorry, correcting myself: The ClosureCleaner uses Kryo's bundled ASM 4 without any reason - simply adjusting the imports to use the common ASM (which is 5.0) should do it ;-) On Mon, Dec 7, 2015 at 8:18 PM, Stephan Ewen wrote: > Flink's own asm is 5.0, but the Kryo version

Strange behaviour of windows

Hi, I have recently experimented a bit with windowing and event-time mechanism in flink and either I do not understand how should it work or there is some kind of a bug. I have prepared two Source Functions. One that emits watermark itself and one that does not, but I have prepared a

Re: Strange behaviour of windows

Forgot to mention. I've checked it both on 0.10 and current master. 2015-12-07 20:32 GMT+01:00 Dawid Wysakowicz : > Hi, > > I have recently experimented a bit with windowing and event-time mechanism > in flink and either I do not understand how should it work or there

Re: Flink Storm

Hi Matthias, Sorry for the confusion. I just used a simple code in the Count Bolt to write the bolt output into a file and was not using BiltFileSink. OutputStream o; try { o = new FileOutputStream("/tmp/wordcount.txt", true); o.write((word + " " + count.toString() + "\n").getBytes());

Re: Using Flink with Scala 2.11 and Java 8

For completeness, could you provide a stack trace of the error message? On Mon, Dec 7, 2015 at 6:56 PM, Maximilian Michels wrote: > Hi Cory, > > Thanks for reporting the issue. Scala should run independently of the > Java version. We are already using ASM version 5.0.4. However,