Joining Windowed Data Streams

Hey community, is there a possibility to join two windowed data streams, instead of joining two data streams on a window? For example if one wants to implement Q1 of SRBench you load the data, create one window definition and then one would combine filters

Custom Aggregate - Example

Hello community, how do I define a custom aggregate function in Flink Streaming (Scala)? Could you please provide an example on how to do that? Thank you and best regards, Philipp

Re: Custom Aggregate - Example

function you should be able to implement any custom aggregations. You can also use foldWindow() if you want to do a functional fold over the window. I hope this helps. Cheers, Aljoscha On Fri, 21 Aug 2015 at 14:51 Philipp Goetze philipp.goe...@tu-ilmenau.de mailto:philipp.goe...@tu-ilmenau.de

Re: NullPointerException when working with Windows

Jul 2015, at 14:02, Philipp Goetze philipp.goe...@tu-ilmenau.de wrote:

NullPointerException when working with Windows

Hey community, I am not sure whether it is a bug or I am doing something wrong. I have a little snippet produced by our project (see below). When I execute it in Eclipse everything works fine. However, when deploying the Jar to the local flink installation I get NullPointer Exceptions after

Submitting jobs from within Scala code

Hi community, in our project we try to submit built Flink programs to the jobmanager from within Scala code. The test program is executed correctly when submitted via the wrapper script bin/flink run ... and also with the webclient. But when executed from within the Scala code nothing seems

Re: Submitting jobs from within Scala code

file| Cheers, Till ​ On Thu, Jul 16, 2015 at 11:23 AM, Philipp Goetze philipp.goe...@tu-ilmenau.de mailto:philipp.goe...@tu-ilmenau.de wrote: Hi Till, the problem is that this is the only output :( Or is it possible to get a more verbose log output? Maybe it is important

Fwd: Re: Submitting jobs from within Scala code

Forwarded Message Subject:Re: Submitting jobs from within Scala code Date: Thu, 16 Jul 2015 14:31:01 +0200 From: Philipp Goetze philipp.goe...@tu-ilmenau.de To: user@flink.apache.org Hey, from the JobManager I do not get any more hints: 13:36:06,674 DEBUG

Re: Flink 0.9 built with Scala 2.11

branch. `mvn clean install -DskipTests -P \!scala-2.10,scala-2.11` command builds Flink with Scala 2.11. Regards, Chiwan Park On Jun 10, 2015, at 9:56 PM, Flavio Pompermaier pomperma...@okkam.it wrote: Nice! On 10 Jun 2015 14:49, Philipp Goetze philipp.goe...@tu-ilmenau.de wrote: Hi community

Re: Flink 0.9 built with Scala 2.11

, at 10:23 PM, Chiwan Park chiwanp...@icloud.com wrote: No. Currently, there are no Flink binaries with scala 2.11 which are downloadable. Regards, Chiwan Park On Jun 10, 2015, at 10:18 PM, Philipp Goetze philipp.goe...@tu-ilmenau.de wrote: Thank you Chiwan! I did not know the master has a 2.11