Re: Nested iterations not supported?

xt without passing through a data sink to collect them into heap or write them to a file? Regards, Pieter-Jan Van Aeken 2015-08-18 12:11 GMT+02:00 Andra Lungu : > Hello Pieter, > > Nested iterations are indeed not supported in Flink. > > http://mail-archives.apache.org/mod_mb

Nested iterations not supported?

java:54) at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:789) at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:580) Regards, Pieter-Jan Van Aeken

nightly builds

Hello, Is there a nightly snapshot build that is exposed through Maven? I couldn't find one in Maven central, but maybe there is another repo somewhere? Regards, Pieter-Jan

GSA based on edge direction

) graph.reverse() graph.run(gsa-outgoing)  ​2. If not, is there some option I can configure to achieve the same result? Regards, Pieter-Jan Van Aeken

Re: Checkstyle in IntelliJ

by 4. Regards, Pieter-Jan Van Aeken Op Dinsdag, 09/06/2015 om 12:04 schreef Aljoscha Krettek: By the way, do you have the Flink checkstyle and scalastyle profiles set in IntelliJ? This way you at least get red errors directly in the IDE. For checkstyle there is Checkstyle-IDEA and for scalastyle

Re: Checkstyle in IntelliJ

files we've not actually modified. Regards, Pieter-Jan Van Aeken Op Dinsdag, 09/06/2015 om 11:10 schreef Till Rohrmann: Hi Pieter-Jan, I'm not aware of an Eclipse or IntellJ auto format profile. I think that all Flink contributors apply their style changes manually. The maven output sho

Checkstyle in IntelliJ

ven/scalastyle-config.xml". >From what I understand, this is only possible in Eclipse? Can anyone perhaps provide me with the Eclipse Profile XML files so that I can use the auto-format function in IntelliJ to make my code comply with the style standards? My additions are written in Scala an

Re: Scala Tuple2 not recognized as a Scala Tuple

Found the solution: Creating the TypeInformation in Scala and then passing it to Java where it is used explicitly in the returns method resolved the issue. Op Maandag, 01/06/2015 om 16:59 schreef Pieter-Jan Van Aeken: >From the Java API, I get an instance of_ DataSet_​ which I wrap with

Scala Tuple2 not recognized as a Scala Tuple

>From the Java API, I get an instance of_ DataSet_​ which I wrap with the method available in _org.apache.flink.api.scala.package. _This works fine when I print out the result, but when I try to write as CSV, I get an exception: java.lang.IllegalArgumentException: requirement failed: CSV output ca

Scala compatibility in Gelly

, and thus I cannot compile. Are there any workarounds for this or will I have to resort to using Java? (I'd rather not) Kind regards, Pieter-Jan Van Aeken