Thank you, I will check this fix in my environment.
Best,
Ovidiu
-Original Message-
From: Aljoscha Krettek [mailto:aljos...@apache.org]
Sent: Friday, October 21, 2016 5:47 PM
To: dev@flink.apache.org
Subject: Re: TopSpeedWindowing - in error: Could not forward element to next
operator
Hi,
the problem is that EvictingWindowOperator uses StreamRecordSerializer to
serialise the contents of the windows. This does not serialise timestamps
so when the objects are deserialised from RocksDB they all have
Long.MIN_VALUE as timestamp. The evictor in the program therefore always
evicts
Hi
I have the latest source code Master.
I think the refactoring you were doing on State Backend gives this issue,
unless the example is not supposed to work
With rocksdb.
At some point collected records's values are null, giving the error..
What do you think?
Best,
Ovidiu
-Original
Hi Ovidiu,
which version of Flink are you using?
Cheers,
Till
On Thu, Oct 20, 2016 at 6:38 PM, Ovidiu Cristian Marcu <
ovidiu.cristian.ma...@huawei.com> wrote:
> Could you check the following issue on master?
>
> When running this example org.apache.flink.streaming.examples.windowing.
>
