sans.com>
> Отправлено: 27 февраля 2017 г. в 21:50
> Кому: Evgeny Kincharov<mailto:evgeny_kincha...@epam.com>
> Копия: user@flink.apache.org<mailto:user@flink.apache.org>
> Тема: Re: Running streaming job on every node of cluster
>
> this may also be a good read:
>
> htt
;
Отправлено: 27 февраля 2017 г. в 21:50
Кому: Evgeny Kincharov<mailto:evgeny_kincha...@epam.com>
Копия: user@flink.apache.org<mailto:user@flink.apache.org>
Тема: Re: Running streaming job on every node of cluster
this may also be a good read:
https://ci.apache.org/projects/flink/fli
des allow
> > it.
> >
> > BR, Evgeny.
> >
> > От: Nico Kruber<mailto:n...@data-artisans.com>
> > Отправлено: 27 февраля 2017 г. в 20:07
> > Кому: user@flink.apache.org<mailto:user@flink.apache.org>
> > Копия: Evgeny Kincharov<mailto:ev
oyment modes allow it.
>
> BR, Evgeny.
>
> От: Nico Kruber<mailto:n...@data-artisans.com>
> Отправлено: 27 февраля 2017 г. в 20:07
> Кому: user@flink.apache.org<mailto:user@flink.apache.org>
> Копия: Evgeny Kincharov<mailto:evgeny_kincha...@epam.com>
> Те
ata-artisans.com>
Отправлено: 27 февраля 2017 г. в 20:07
Кому: user@flink.apache.org<mailto:user@flink.apache.org>
Копия: Evgeny Kincharov<mailto:evgeny_kincha...@epam.com>
Тема: Re: Running streaming job on every node of cluster
Hi Evgeny,
I tried to reproduce your example with the foll
Hi Evgeny,
I tried to reproduce your example with the following code, having another
console listening with "nc -l 12345"
env.setParallelism(2);
env.addSource(new SocketTextStreamFunction("localhost", 12345, " ", 3))
.map(new MapFunction() {
@Override
