Hi,
Could you confirm the size of your topology.jar file? Then compare this with the nimbus.thrift.max_buffer_size ???? parameter in your storm.yaml configuration. This storm.yaml file will be present in the storm directory in your nimbus node. In case the above parameter is missing from your storm.yaml file, it is likely set to the default value (which may be smaller than your topology.jar file). Just add a line setting the value (in bytes) to a value large enough to encompass your. E.g. nimbus.thrift.max_buffer_size: 40000000 Regards, Deb ________________________________ From: researcher cs <[email protected]> Sent: Monday, September 28, 2015 8:56 AM To: [email protected] Subject: Connection refused in submitting topology I'm new in storm and facing this problem during submitting topology this is some of data in log file of nimbus [ERROR] Unexpected exception while invoking! java.lang.NullPointerException at clojure.lang.Numbers.ops(Numbers.java:942) [ERROR] Unexpected exception while invoking! java.lang.NullPointerException at clojure.lang.Numbers.ops(Numbers.java:942) at clojure.lang.Numbers.isPos(Numbers.java:94) at clojure.core$take$fn__4112.invoke(core.clj:2500) at clojure.lang.LazySeq.sval(LazySeq.java:42) at clojure.lang.LazySeq.seq(LazySeq.java:60) at clojure.lang.RT.seq(RT.java:473) at clojure.core$seq.invoke(core.clj:133) at clojure.core$concat$fn__3804.invoke(core.clj:662) at clojure.lang.LazySeq.sval(LazySeq.java:42) at clojure.lang.LazySeq.seq(LazySeq.java:60) at clojure.lang.RT.seq(RT.java:473) at clojure.core$seq.invoke(core.clj:133) at clojure.core$concat$cat__3806$fn__3807.invoke(core.clj:671) at clojure.lang.LazySeq.sval(LazySeq.java:42) at clojure.lang.LazySeq.seq(LazySeq.java:60) at clojure.lang.RT.seq(RT.java:473) at clojure.core$seq.invoke(core.clj:133) and this what i have in submitting topology Exception in thread "main" java.lang.RuntimeException: org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refused at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:36) at backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:17) at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:69) at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:40)
