If you really what to run one operation per node. You start 1
TaskManager with 1 slot on every node. For each operation you set a new
chain and a new slot sharing group.
Timo
Am 23.06.17 um 15:03 schrieb AndreaKinn:
Hi Timo, thanks for your answer.
I think my elaboration are not too much heavy so I imagine I will have no
advantages to "parallelize" streams.
In my mind I have this pipeline:
<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n13969/Screen_Shot_2017-06-22_at_19.png>
And this is exactly what I want develop: a need a pipeline where a node runs
fixed operation and forward elaborated data to the next and so on. How can I
obtain this?
If I understand "chaining" considers the possibility of execute multiple
operations on same thread to improve performance.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-nodes-number-on-Flink-tp13927p13969.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
