Great! Thanks for letting us know.
On Wed, 11 Jan 2017 at 12:44 Sujit Sakre
wrote:
> Hi Aljoscha,
>
> I have realized that the output stream is not defined separately in the
> code below, and hence the input values are getting in the sink. After
> defining a separate output stream it works.
>
>
Hi Aljoscha,
I have realized that the output stream is not defined separately in the
code below, and hence the input values are getting in the sink. After
defining a separate output stream it works.
We have now confirmed that the windows are processed separately as per the
groupings.
Thanks.
*
Hi Aljoscha,
Thanks.
I have used the following code for testing:
main
keyedStream.keyBy(4)
.window(SlidingEventTimeWindows.of(Time.minutes6), Time.minutes(2))) // 6
min window with 2 min sliding window
.apply(new CustomSlidingWindowFunction());
keyedStream.addSink(new SinkFunction>() {
/**
*
Hi,
instead of writing to files, could you please simply output a value using
the Collector and then write the result stream of the window operation to a
sink (such as a file sink) to see how many windows are being processed.
Having side effects (especially output) in user functions can lead to
pro
Hi,
In the link (
http://stackoverflow.com/questions/41143518/sliding-processing-time-window-computes-inconsistent-results),
Fabian has mentioned that if Event Time is used, consistent results are
possible.
However, that's not the case with us. We are getting very random results.
Please suggest.
