>> it. Will take a deeper look an monday.
>>
>> Best,
>> Stefan
>>
>>> Am 11.08.2017 um 20:55 schrieb Daiqing Li >> <mailto:lidaiqing1...@gmail.com>>:
>>>
>>> Hi,
>>>
>>> I am running fling 1.
Hi,
I am running fling 1.3.1 on EMR. But I am getting this exception after running
for a while.
java.lang.RuntimeException: Exception occurred while processing valve output
watermark:
at
org.apache.flink.streaming.runtime.io.StreamInputProcessor$ForwardingValveOutputHandler.handleWat
ryID map.
>
>> On 10 Aug 2017, at 14:54, Daiqing Li wrote:
>>
>> Oh sorry, the data in {} is not empty because I hide private information
>> about my model. Do you have that same conclusion?
>>> On Aug 10, 2017, at 8:52 AM, Dawid Wysakowicz
>>>
which
> seems odd as if your event was empty.
>
> Generally speaking as I understand this Exception is thrown because the
> hashcode of your event changes during serialization, and access to some
> internal temporary cache is broken.
>
>> On 10 Aug 2017, at 14:29, Daiqi
ode for that job or at least a minimal example to reproduce
> this behaviour. I fear we won’t be able to help you without any further
> info.
>
> Regards,
> Dawid
>
> > On 10 Aug 2017, at 14:10, Daiqing Li wrote:
> >
> > Hi Flink user,
> >
> > I am u
Hi Flink user,
I am using FsStateBackend and AWS EMR YARN to run a CEP job. I got this
exception after running for a while. Could anyone give me some help to
debug this? I try parallelism 1, and it has the same problem. I also try
reimplemented hashcode and equals method. I use UUID as hashcode ri
Hi guys,
We are using flink cep to detect pattern. Here is the exception we got:
org.apache.flink.streaming.api.operators.InternalTimeServiceManager.
advanceWatermark(InternalTimeServiceManager.java:107)
at org.apache.flink.streaming.api.operators.AbstractStreamOperator.
processWatermark(Abstract
