Hi, this is related to your other question about count windows. The source emits 29 values so we only have two count-windows with 10 elements each. The last window is never triggered.
Cheers, Aljoscha On Wed, 20 Apr 2016 at 23:52 Kostya Kulagin <kkula...@gmail.com> wrote: > I think it has smth to do with parallelism and I probably do not have > clear understanding how parallelism works in flink but in this example: > > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > DataStreamSource<Long> source = env.addSource(new SourceFunction<Long>() { > > @Override > public void run(SourceContext<Long> ctx) throws Exception { > LongStream.range(0, 29).forEach(ctx::collect); > } > > @Override > public void cancel() { > > } > }); > > source.countWindowAll(10).apply(new AllWindowFunction<Long, Long, > GlobalWindow>() { > @Override > public void apply(GlobalWindow window, Iterable<Long> values, > Collector<Long> out) throws Exception { > for (Long value : values) { > if (value % 3 == 0) { > out.collect(value); > } > } > } > }).print(); > > env.execute("yoyoyo"); > > Why my output is like this: > > 4> 9 > 1> 0 > 1> 12 > 3> 6 > 3> 18 > 2> 3 > 2> 15 > > ? I.e. where id s value of 24 for example? I expect to see it. What am I > doing wrong? >