Hi,
Thank you for your reply! I will post it.
> On Aug 12, 2017, at 4:20 AM, Kostas Kloudas
> wrote:
>
> Hi Daiqing,
>
> I think Stefan is right and this will be fixed in the upcoming release.
> Could you open a JIRA for it with the Exception that you posted here?
>
> Thanks,
> Kostas
>
>> O
Hi Daiqing,
I think Stefan is right and this will be fixed in the upcoming release.
Could you open a JIRA for it with the Exception that you posted here?
Thanks,
Kostas
> On Aug 12, 2017, at 10:05 AM, Stefan Richter
> wrote:
>
> Hi,
>
> from a quick look, I would say this is likely a problem
Hi,
from a quick look, I would say this is likely a problem with the NFASerializer:
this class seems to be stateful, but its 'duplicate()‘ method is simply
returning ‚this‘. This means that code which relies on duplication of
serializers to shield against concurrent accesses can break, because
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
