Учитывая текущее задание Spark Streaming, я хотел бы отправить несколько сигналов, чтобы сказать ему, что он должен делать что-то, что обычно выполняется драйвером при запуске.
Например, JSON (файл конфигурации) читается и затем передается каждому исполнителю в начале. JSON задает поведение для распределенного процесса.
Но, возможно, мне потребуется изменить этот JSON, и я хочу, очевидно, повторно отправить его каждому исполнителю ...
Так есть ли лучший способ сделать это, чем другие?