【问题标题】:Apache storm - supervisor port property defining in storm.yaml in storm 1.1.1Apache Storm - Storm 1.1.1 中的 Storm.yaml 中定义的主管端口属性
【发布时间】:2017-09-03 16:48:48
【问题描述】:

storm.yaml(apache-storm 1.1.1) 中的 supervisor 属性 出现以下异常。它适用于风暴 0.9.7。主管.slots.ports:

– 6700 – 6701 – 6702 – 6703

c:\home>线程“main”中的storm nimbus异常 java.lang.ExceptionInInitializerError 在 java.lang.Class.forName0(本机方法) 在 java.lang.Class.forName(Class.java:348) 在 clojure.lang.RT.classForName(RT.java:2154) 在 clojure.lang.RT.classForName(RT.java:2163) 在 clojure.lang.RT.loadClassForName(RT.java:2182) 在 clojure.lang.RT.load(RT.java:436) 在 clojure.lang.RT.load(RT.java:412) 在 clojure.core$load$fn__5448.invoke(core.clj:5866) 在 clojure.core$load.doInvoke(core.clj:5865) 在 clojure.lang.RestFn.invoke(RestFn.java:408) 在 clojure.core$load_one.invoke(core.clj:5671) 在 clojure.core$load_lib$fn__5397.invoke(core.clj:5711) 在 clojure.core$load_lib.doInvoke(core.clj:5710) 在 clojure.lang.RestFn.applyTo(RestFn.java:142) 在 clojure.core$apply.invoke(core.clj:632) 在 clojure.core$load_libs.doInvoke(core.clj:5753) 在 clojure.lang.RestFn.applyTo(RestFn.java:137) 在 clojure.core$apply.invoke(core.clj:634) 在 clojure.core$use.doInvoke(core.clj:5843) 在 clojure.lang.RestFn.invoke(RestFn.java:408) 在 org.apache.storm.command.config_value$loading__5340__auto____12278.invoke(config_value .clj:16) 在 org.apache.storm.command.config_value__init.load(未知来源) 在 org.apache.storm.command.config_value__init.(未知来源) 在 java.lang.Class.forName0(本机方法) 在 java.lang.Class.forName(Class.java:348) 在 clojure.lang.RT.classForName(RT.java:2154) 在 clojure.lang.RT.classForName(RT.java:2163) 在 clojure.lang.RT.loadClassForName(RT.java:2182) 在 clojure.lang.RT.load(RT.java:436) 在 clojure.lang.RT.load(RT.java:412) 在 clojure.core$load$fn__5448.invoke(core.clj:5866) 在 clojure.core$load.doInvoke(core.clj:5865) 在 clojure.lang.RestFn.invoke(RestFn.java:408) 在 clojure.lang.Var.invoke(Var.java:379) 在 org.apache.storm.command.config_value.(Unknown Source) Caused by: java.lang.IllegalArgumentException: Field SUPERVISOR_SLOTS_PORTS 必须是接口 java.lang.Iterable 类型。 目的: ? 6700 ? 6701 ? 6702 ? 6703 实际类型:类 java.lang.String 在 org.apache.storm.validation.ConfigValidation$SimpleTypeValidator.validateField(ConfigValidation.java:90) 在 org.apache.storm.validation.ConfigValidation$NoDuplicateInListValidator.validateField(ConfigValidation.java:2 03) 在 org.apache.storm.validation.ConfigValidation.validateField(ConfigValidation.java:640) 在 org.apache.storm.validation.ConfigValidation.validateFields(ConfigValidation.java:675) 在 org.apache.storm.validation.ConfigValidation.validateFields(ConfigValidation.java:654) 在 org.apache.storm.config$validate_configs_with_schemas.invoke(config.clj:74) 在 org.apache.storm.config$read_storm_config.invoke(config.clj:79) 在 org.apache.storm.config$fn__908.invoke(config.clj:100) 在 org.apache.storm.config__init.load(未知来源) 在 org.apache.storm.config__init.(未知来源) ... 35 个以上(此时出乎意料。

【问题讨论】:

    标签: apache-storm


    【解决方案1】:

    在apachestorm 1.1.1下面的属性格式

    supervisor.slots.ports:

    [6700,6701,6702,6703]

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2015-07-07
      • 1970-01-01
      • 2015-08-15
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2020-05-11
      相关资源
      最近更新 更多