Развертывание штормовой топологии в разных кластерах с помощью Flux
Я использую Flux для развертывания моих топологий в удаленном кластере. Есть ли способ пройти nimbus.seeds через командную строку, чтобы я мог развернуть мои топологии в разных кластерах с помощью Flux.
Я использую эту ссылку здесь для развертываний с использованием Flux. Это говорит о том, что мы должны использовать -c флаг, но его бесполезно. Я запускаю следующую команду:
storm jar path\to\jar org.apache.storm.flux.Flux --remote .\config.yaml --filter .\src\main\resources\application.properties -c 'nimbus.seeds=["my-nimbus"]'
Я получаю следующее исключение:
Exception in thread "main" java.lang.IllegalArgumentException: Field NIMBUS_SEEDS must be an Iterable but was a class java.lang.String
at org.apache.storm.validation.ConfigValidationUtils$2.validateField(ConfigValidationUtils.java:125)
at org.apache.storm.validation.ConfigValidationUtils$NestableFieldValidator.validateField(ConfigValidationUtils.java:48)
at org.apache.storm.validation.ConfigValidation$ListEntryTypeValidator.validateField(ConfigValidation.java:304)
at org.apache.storm.validation.ConfigValidation$ListEntryTypeValidator.validateField(ConfigValidation.java:299)
at org.apache.storm.validation.ConfigValidation.validateField(ConfigValidation.java:640)
at org.apache.storm.validation.ConfigValidation.validateFields(ConfigValidation.java:675)
at org.apache.storm.validation.ConfigValidation.validateFields(ConfigValidation.java:654)
at org.apache.storm.StormSubmitter.validateConfs(StormSubmitter.java:559)
at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:207)
at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387)
at org.apache.storm.flux.Flux.runCli(Flux.java:176)
at org.apache.storm.flux.Flux.main(Flux.java:103)
Заранее спасибо:)