eagle-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (EAGLE-1014) No data in alertEngineSpout - handle exception
Date Tue, 02 May 2017 18:31:04 GMT

    [ https://issues.apache.org/jira/browse/EAGLE-1014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993459#comment-15993459
] 

ASF GitHub Bot commented on EAGLE-1014:
---------------------------------------

Github user asfgit closed the pull request at:

    https://github.com/apache/eagle/pull/927


> 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)

Mime
View raw message