2016-02-05 50 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