java.lang.RuntimeException: java.lang.RuntimeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/warehouse_prices/partitions

storm-user | Benjamin Cuthbert | 2 years ago
  1. 0

    Re: zookeeper paths not created on startup

    storm-user | 2 years ago | Benjamin Cuthbert
    java.lang.RuntimeException: java.lang.RuntimeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/warehouse_prices/partitions
  2. 0

    kafka spout can't connect to kafka topic

    Stack Overflow | 1 year ago | supernovae
    java.lang.RuntimeException: java.lang.RuntimeException: java.lang.IllegalArgumentException: Invalid path string "/brokers/topics//test-topic-multi/partitions" caused by empty node name specified @16
  3. 0

    Docker-compose with Storm 0.10.0 and Zookeeper (connection loss)

    Stack Overflow | 8 months ago | Dan Cristian Rotaru
    java.lang.RuntimeException: java.lang.RuntimeException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /brokers/topics/sessionTest/partitions
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    I was upgrading our topologies to storm-0.9.3 this [commit|https://github.com/apache/storm/commit/2596e335f27a57784a93a57823bd93dde587909f] introduced a change that threw me for a loop. When submitting my topology I got the following error. {code} [main] ERROR storm.kafka.DynamicBrokersReader - Couldn't connect to zookeeper java.lang.IllegalArgumentException: Don't know how to convert null to int at backtype.storm.utils.Utils.getInt(Utils.java:301) ~[storm-core-0.9.3.jar:0.9.3] at storm.kafka.DynamicBrokersReader.<init>(DynamicBrokersReader.java:47) ~[gambit-storm-threads-0.0.1-SNAPSHOT-jar-with-dependencies.jar:na] at com.pearson.gambit.threads.storm.ThreadsTopology.main(ThreadsTopology.java:45) [gambit-storm-threads-0.0.1-SNAPSHOT-jar-with-dependencies.jar:na] Exception in thread "main" java.lang.RuntimeException: java.lang.RuntimeException: java.lang.NullPointerException at storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:81) at com.pearson.gambit.threads.storm.ThreadsTopology.main(ThreadsTopology.java:48) Caused by: java.lang.RuntimeException: java.lang.NullPointerException at storm.kafka.DynamicBrokersReader.getNumPartitions(DynamicBrokersReader.java:94) at storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:65) ... 1 more Caused by: java.lang.NullPointerException at storm.kafka.DynamicBrokersReader.getNumPartitions(DynamicBrokersReader.java:91) ... 2 more {code} It took me a while to figure out that this error stems from missing the {code}backtype.storm.Config.STORM_ZOOKEEPER_CONNECTION_TIMEOUT{code} property in the conf map provided to the {code}storm.kafka.DynamicBrokersReader{code} constructer. It would be nice to check the required configuration parameters and throw a RuntimeException if any are missing.

    Apache's JIRA Issue Tracker | 2 years ago | Curtis Allen
    java.lang.RuntimeException: java.lang.RuntimeException: java.lang.NullPointerException
  6. 0

    what is zookeeper.broker.path

    Stack Overflow | 1 year ago | Sathish
    java.lang.RuntimeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/<name>/partitions

    2 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.RuntimeException

      java.lang.RuntimeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/warehouse_prices/partitions

      at storm.kafka.DynamicBrokersReader.getBrokerInfo()
    2. storm.kafka
      DynamicBrokersReader.getBrokerInfo
      1. storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:81)[storm-kafka-0.9.4.jar:0.9.4]
      1 frame
    3. storm.kafka.trident
      ZkBrokerReader.<init>
      1. storm.kafka.trident.ZkBrokerReader.<init>(ZkBrokerReader.java:42)[storm-kafka-0.9.4.jar:0.9.4]
      1 frame
    4. storm.kafka
      KafkaSpout.open
      1. storm.kafka.KafkaUtils.makeBrokerReader(KafkaUtils.java:57)[storm-kafka-0.9.4.jar:0.9.4]
      2. storm.kafka.KafkaSpout.open(KafkaSpout.java:87)[storm-kafka-0.9.4.jar:0.9.4]
      2 frames
    5. backtype.storm.daemon
      executor$fn__3371$fn__3386.invoke
      1. backtype.storm.daemon.executor$fn__3371$fn__3386.invoke(executor.clj:522)[storm-core-0.9.4.jar:0.9.4]
      1 frame
    6. backtype.storm
      util$async_loop$fn__460.invoke
      1. backtype.storm.util$async_loop$fn__460.invoke(util.clj:461)[storm-core-0.9.4.jar:0.9.4]
      1 frame
    7. Clojure
      AFn.run
      1. clojure.lang.AFn.run(AFn.java:24)[clojure-1.5.1.jar:na]
      1 frame
    8. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:744)[na:1.7.0_51]
      1 frame