Задача Spark DStream.mapWithState не сбалансирована для всех исполнителей, что со мной? - PullRequest
0 голосов
/ 16 января 2019

4 исполнителя.и 35 данных раздела, нет перекоса данных.на этапе mapWithState существует 10 задач, но все они выполняются в одном исполнителе (мы называем его исполнителем 1), а не доводят 10 заданий до 4 исполнителей.как исправить эту ошибку?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...