Конфигурация шторма Apache

Question

У меня возникла проблема с установкой планировщика изоляции для топологии. В основном я пытаюсь установить количество машин в одну топологию, как показано ниже.

Map<String, Number> topologyToMachines = new HashMap<String, Number>(); 
topologyToMachines.put(TOPOLOGY_NAME, 1); 
config.put(Config.STORM_SCHEDULER, "backtype.storm.scheduler.IsolationScheduler"); 
config.put(Config.ISOLATION_SCHEDULER_MACHINES, topologyToMachines); 

Если я установлен как указано выше, nimbus не посвящает узел этой топологии. Для этой топологии я назначил двух работников. Эти два сотрудника назначаются двум узлам, а не только одному узлу.

Но если я изменю конфигурацию через storm.yaml в узле nimbus и отправлю ту же топологию, для этой топологии назначен только один узел.

Это ошибка в Storm? Я использую версию 0.9.1.

Answer 1

Это поведение кажется нормальным. Экстракт Storm 0.8.2 release notes, когда были добавлены параметры изоляции.

Любые топологии, представленные в кластер, не указанные здесь, не будут изолированы. Обратите внимание, что пользователь Storm не может повлиять на настройки изоляции - это разрешается только администратору кластера (это очень интенсивно).