Re: multiple processing of streams

2016-10-24 Thread Fabian Hueske
d get rid of my heap issues. > > > > Thanks! > > > > *From: *Fabian Hueske > *Reply-To: *"user@flink.apache.org" > *Date: *Monday, October 24, 2016 at 2:27 PM > > *To: *"user@flink.apache.org" > *Subject: *Re: multiple processing of st

Re: multiple processing of streams

2016-10-24 Thread robert.lancaster
should get rid of my heap issues. Thanks! From: Fabian Hueske Reply-To: "user@flink.apache.org" Date: Monday, October 24, 2016 at 2:27 PM To: "user@flink.apache.org" Subject: Re: multiple processing of streams Hi Robert, thanks for the update. Regarding the SessionWindow.

Re: multiple processing of streams

2016-10-24 Thread Fabian Hueske
link.apache.org" > *Date: *Friday, October 21, 2016 at 5:17 PM > *To: *"user@flink.apache.org" > *Subject: *Re: multiple processing of streams > > > > Hi Robert, > > it is certainly possible to feed the same DataStream into two (or more) > operators. > > Both

Re: multiple processing of streams

2016-10-24 Thread robert.lancaster
5:17 PM To: "user@flink.apache.org" Subject: Re: multiple processing of streams Hi Robert, it is certainly possible to feed the same DataStream into two (or more) operators. Both operators should then process the complete input stream. What you describe is an unintended behavior. Can

Re: multiple processing of streams

2016-10-21 Thread Fabian Hueske
Hi Robert, it is certainly possible to feed the same DataStream into two (or more) operators. Both operators should then process the complete input stream. What you describe is an unintended behavior. Can you explain how you figure out that both window operators only receive half of the events?

multiple processing of streams

2016-10-19 Thread robert.lancaster
Is it possible to process the same stream in two different ways? I can’t find anything in the documentation definitively stating this is possible, but nor do I find anything stating it isn’t. My attempt had some unexpected results, which I’ll explain below: Essentially, I have a stream of dat