Hi, All Merry Christmas!
I am running a topology to getting data from Kafka and write into DB, for DB dump, I am using RDBMSDumperBolt, it works fine when I am sending topology to localcluster, but fails when I am sending to storm cluster, below is what I've seen on the storm UI Bolts (All time) dumperBolt <http://10.100.70.128:8080/component.html?id=dumperBolt&topology_id=Writer-1-1419442606> 1 1 0 0 0.000 0.000 0 0.000 0 0 pof-kstorm-dev1.pof.local 6703 <http://pof-kstorm-dev1.pof.local:8000/log?file=worker-6703.log> java.lang.RuntimeException: java.lang.NullPointerException at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) at backtype.storm.utils.DisruptorQueue.consumeBatchWhe Any ideas about this type of errors? thanks Alec
