我是新來的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)
supervisor.scheduler.meta需要一個java Map實例 - 基本上是一個關鍵值對。你可能想要代表「特殊監督者」或預期的價值以代表java映射yaml –