flink-extended / flink-remote-shuffle

Remote Shuffle Service for Flink
Apache License 2.0
191 stars 57 forks source link

Introduce rest APIs for dynamic disk online/offline #6

Open wsry opened 2 years ago

wsry commented 2 years ago

Motivation

Based on the rest API, we can remove or add disk dynamically without restarting the cluster. For example, we can remove a bad disk or we can add more new disks.

Changes

New rest APIs need to be added together with the corresponding handler. In the handler, disks are removed from or added to the disk list. Both removing one disk from all ShuffleWorkers or removing one disk of a specific ShuffleWorker should be supported.

Test