Hi
I'm pretty new to Flink and stream processing in general but I'm writing a
thesis about it and I have a small question regarding WindowFunctions (WF).
I have one large WF that does essentially two things: counting how much
events there are in a window and calculating the difference between this
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,
The config should be *fs.s3a.impl* instead of *fs.s3.impl*
Also when you are providing the S3 write path in config file or directly in
code start with *s3a://*
Regards,
Vinay Patil
On Sat, Aug 12, 2017 at 6:07 AM, ant burton [via Apache Flink User Mailing
List archive.] wrote:
> Hello,
It is solvable? I'm not an expert of this stuff and the cluster is managed by
the lab responsible. Maybe I can ask him to do something in order to solve.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-during-Kafka-connection-tp14822p14
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
