Hi, Apache Storm has this cool feature that one can "rebalance a topology" during runtime to handle the changes in the streaming workload. Practically this means adjusting the number of worker machines and the parallelism of the spouts and bolts.
Translated to Flink terms this would mean changing the numberOfSubtasks field of the AbstractJobVertices of the JobGraph during runtime (amongst others, e.g. updating the numberOfOutputChannels in the partitioners accordingly). Is there any support for achieving this currently? Cheers, Marton
