我对ApacheStorm还不熟悉,现在正在尝试pluggable scheduler来安排任务分配:哪个任务应该在哪个主管上运行。
我尝试在supervisor节点的storm.yaml文件中设置“supervisor.scheduler.meta”值,如下所示,当我尝试运行supervisor时,出现非法参数异常。我使用的是apache storm 0.10.0。你能指导我解决这个问题吗。请在下面找到配置文件和错误日志
storm.yaml
-----------
supervisor.scheduler.meta: "special-supervisor"
error-log
----
java.lang.IllegalArgumentException: field supervisor.scheduler.meta 'special-supervisor' must be a 'java.util.Map'
at backtype.storm.config$fn$reify__880.validateField(config.clj:58)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
at backtype.storm.config$validate_configs_with_schemas.invoke(config.clj:118)
at backtype.storm.config$read_storm_config.invoke(config.clj:123)
at backtype.storm.command.config_value$_main.invoke(config_value.clj:22)
at clojure.lang.AFn.applyToHelper(AFn.java:154)
at clojure.lang.AFn.applyTo(AFn.java:144)
1条答案
按热度按时间e4yzc0pl1#
Map条目需要有键和值。例如:
其中“姓名”是关键,“特别主管”是价值观。