flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexandru Gutan <alex.guta...@gmail.com>
Subject Parallelism questions
Date Mon, 14 Jan 2019 14:26:02 GMT
Hi everyone!

1. Is there a way to increase the parallelism (e.g. through REST) of some
operators in a job without re-deploying the job? I found this
<https://stackoverflow.com/questions/50719147/apache-flink-guideliness-for-setting-parallelism>
answer which mentions scaling at runtime on Yarn/Mesos. Is it possible?
How? Support for Kubernetes?
2. What happens when the number of parallel operator instances exceeds the
number of task slots? For example: a job with a source (parallelism 3), a
map (parallelism 8), a sink (parallelism 3), total of *14* operator
instances and a setup with *8* task slots. Will the operators get chained?
What if I disable operator chaining?

Thank you!

Mime
View raw message