2016-02-05 22 views
1

我是新来的apache风暴,当前正在尝试Pluggable Scheduler,调度任务分配:应该运行哪个任务主管。Apache Storm:IllegalArgumentException:field supervisor.scheduler.meta必须是'java.util.Map'

我试图在supervisor节点的storm.yaml文件中设置“supervisor.scheduler.meta”值,如下图所示,当我尝试运行supervisor时,我最终得到了非法参数exception.I正在使用apache风暴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) 
+0

supervisor.scheduler.meta需要一个java Map实例 - 基本上是一个关键值对。你可能想要代表“特殊监督者”或预期的价值以代表java映射yaml –

回答

1

映射条目需要有键和值。例如:

supervisor.scheduler.meta: 
    name: "special-supervisor" 

其中“name”是关键字,“special-supervisor”是值。

+0

Thankyou的格式,添加名称作为关键工作 – Praful