[ https://issues.apache.org/jira/browse/EAGLE-1014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jayesh resolved EAGLE-1014. --------------------------- Resolution: Fixed > No data in alertEngineSpout - handle exception > ---------------------------------------------- > > Key: EAGLE-1014 > URL: https://issues.apache.org/jira/browse/EAGLE-1014 > Project: Eagle > Issue Type: Bug > Affects Versions: v0.5.0 > Reporter: Zhao, Qingwen > Assignee: Zhao, Qingwen > > Found the following exception log > {code} > 2017-04-27 03:26:40 Thread-11-alertEngineSpout-EventThread > org.apache.eagle.alert.engine.spout.CorrelationSpout [ERROR] error applying > new SpoutSpec > java.lang.RuntimeException: java.lang.RuntimeException: No leader found for > partition 3 > at > storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:92) > ~[stormjar.jar:na] > at storm.kafka.trident.ZkBrokerReader.<init>(ZkBrokerReader.java:42) > ~[stormjar.jar:na] > at storm.kafka.KafkaUtils.makeBrokerReader(KafkaUtils.java:57) > ~[stormjar.jar:na] > at storm.kafka.KafkaSpoutWrapper.open(KafkaSpoutWrapper.java:79) > ~[stormjar.jar:na] > at > org.apache.eagle.alert.engine.spout.CorrelationSpout.createKafkaSpout(CorrelationSpout.java:355) > ~[stormjar.jar:na] > at > org.apache.eagle.alert.engine.spout.CorrelationSpout.onReload(CorrelationSpout.java:259) > ~[stormjar.jar:na] > at > org.apache.eagle.alert.engine.spout.CorrelationSpout.onSpoutSpecChange(CorrelationSpout.java:162) > ~[stormjar.jar:na] > at > org.apache.eagle.alert.engine.coordinator.impl.AbstractMetadataChangeNotifyService.lambda$notifySpout$0(AbstractMetadataChangeNotifyService.java:91) > [stormjar.jar:na] > at java.util.ArrayList.forEach(ArrayList.java:1249) ~[na:1.8.0_91] > at > org.apache.eagle.alert.engine.coordinator.impl.AbstractMetadataChangeNotifyService.notifySpout(AbstractMetadataChangeNotifyService.java:91) > [stormjar.jar:na] > at > org.apache.eagle.alert.engine.coordinator.impl.ZKMetadataChangeNotifyService.onNewConfig(ZKMetadataChangeNotifyService.java:148) > ~[stormjar.jar:na] > at > org.apache.eagle.alert.config.ConfigBusConsumer.lambda$new$0(ConfigBusConsumer.java:44) > ~[stormjar.jar:na] > at > org.apache.curator.framework.recipes.cache.NodeCache$4.apply(NodeCache.java:293) > ~[stormjar.jar:na] > at > org.apache.curator.framework.recipes.cache.NodeCache$4.apply(NodeCache.java:287) > ~[stormjar.jar:na] > at > org.apache.curator.framework.listen.ListenerContainer$1.run(ListenerContainer.java:92) > ~[stormjar.jar:na] > at > com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:253) > ~[guava-11.0.2.jar:na] > at > org.apache.curator.framework.listen.ListenerContainer.forEach(ListenerContainer.java:83) > ~[stormjar.jar:na] > at > org.apache.curator.framework.recipes.cache.NodeCache.setNewData(NodeCache.java:284) > ~[stormjar.jar:na] > at > org.apache.curator.framework.recipes.cache.NodeCache.processBackgroundResult(NodeCache.java:252) > ~[stormjar.jar:na] > at > org.apache.curator.framework.recipes.cache.NodeCache.access$300(NodeCache.java:53) > ~[stormjar.jar:na] > at > org.apache.curator.framework.recipes.cache.NodeCache$3.processResult(NodeCache.java:111) > ~[stormjar.jar:na] > at > org.apache.curator.framework.imps.CuratorFrameworkImpl.sendToBackgroundCallback(CuratorFrameworkImpl.java:730) > ~[stormjar.jar:na] > at > org.apache.curator.framework.imps.CuratorFrameworkImpl.processBackgroundOperation(CuratorFrameworkImpl.java:516) > ~[stormjar.jar:na] > at > org.apache.curator.framework.imps.GetDataBuilderImpl$3.processResult(GetDataBuilderImpl.java:254) > ~[stormjar.jar:na] > at > org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:561) > ~[zookeeper-3.4.6.2.2.0.0-2041.jar:3.4.6-2041--1] > at > org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:498) > ~[zookeeper-3.4.6.2.2.0.0-2041.jar:3.4.6-2041--1] > Caused by: java.lang.RuntimeException: No leader found for partition 3 > at > storm.kafka.DynamicBrokersReader.getLeaderFor(DynamicBrokersReader.java:131) > ~[stormjar.jar:na] > at > storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:79) > ~[stormjar.jar:na] > ... 25 common frames omitted > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)