;
Отправлено: 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
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,
I have the simplest streaming job, and I want to distribute my job on every
node of my Flink cluster.
Job is simple:
source (SocketTextStream) -> map -> sink (AsyncHtttpSink).
When I increase parallelism of my job when deploying or directly in code, no
effect because source is can't work
