atlas-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bill (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ATLAS-633) "kafka.common.NoReplicaOnlineException" exception on atlas startup
Date Wed, 16 Aug 2017 02:37:00 GMT

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

Bill commented on ATLAS-633:
----------------------------

[~ayubkhan]  Hi, is this problem you finally solved? :D

> "kafka.common.NoReplicaOnlineException" exception on atlas startup
> ------------------------------------------------------------------
>
>                 Key: ATLAS-633
>                 URL: https://issues.apache.org/jira/browse/ATLAS-633
>             Project: Atlas
>          Issue Type: Bug
>    Affects Versions: trunk
>            Reporter: Ayub Pathan
>
> "kafka.common.NoReplicaOnlineException" exception on atlas startup
> {noformat}
> 2016-04-05 11:01:54,811 INFO  - [main:] ~ [Socket Server on Broker 1], Started 1 acceptor
threads (SocketServer:68)
> 2016-04-05 11:01:54,828 INFO  - [ExpirationReaper-1:] ~ [ExpirationReaper-1], Starting
 (DelayedOperationPurgatory$ExpiredOperationReaper:68)
> 2016-04-05 11:01:54,828 INFO  - [ExpirationReaper-1:] ~ [ExpirationReaper-1], Starting
 (DelayedOperationPurgatory$ExpiredOperationReaper:68)
> 2016-04-05 11:01:54,852 INFO  - [main:] ~ [Controller 1]: Controller starting up (KafkaController:68)
> 2016-04-05 11:01:54,862 INFO  - [main:] ~ Creating /controller (is it secure? false)
(ZKCheckedEphemeral:68)
> 2016-04-05 11:01:54,867 INFO  - [main:] ~ Result of znode creation is: OK (ZKCheckedEphemeral:68)
> 2016-04-05 11:01:54,868 INFO  - [main:] ~ 1 successfully elected as leader (ZookeeperLeaderElector:68)
> 2016-04-05 11:01:54,868 INFO  - [main:] ~ [Controller 1]: Broker 1 starting become controller
state transition (KafkaController:68)
> 2016-04-05 11:01:54,870 INFO  - [main:] ~ [Controller 1]: Initialized controller epoch
to 1 and zk version 0 (KafkaController:68)
> 2016-04-05 11:01:54,872 INFO  - [main:] ~ [Controller 1]: Controller 1 incremented epoch
to 2 (KafkaController:68)
> 2016-04-05 11:01:54,939 INFO  - [main:] ~ [Controller 1]: Partitions undergoing preferred
replica election:  (KafkaController:68)
> 2016-04-05 11:01:54,939 INFO  - [main:] ~ [Controller 1]: Partitions that completed preferred
replica election:  (KafkaController:68)
> 2016-04-05 11:01:54,940 INFO  - [main:] ~ [Controller 1]: Resuming preferred replica
election for partitions:  (KafkaController:68)
> 2016-04-05 11:01:54,943 INFO  - [main:] ~ [Controller 1]: Partitions being reassigned:
Map() (KafkaController:68)
> 2016-04-05 11:01:54,944 INFO  - [main:] ~ [Controller 1]: Partitions already reassigned:
List() (KafkaController:68)
> 2016-04-05 11:01:54,945 INFO  - [main:] ~ [Controller 1]: Resuming reassignment of partitions:
Map() (KafkaController:68)
> 2016-04-05 11:01:54,949 INFO  - [main:] ~ [Controller 1]: List of topics to be deleted:
 (KafkaController:68)
> 2016-04-05 11:01:54,949 INFO  - [main:] ~ [Controller 1]: List of topics ineligible for
deletion: ATLAS_HOOK,ATLAS_ENTITIES (KafkaController:68)
> 2016-04-05 11:01:54,951 INFO  - [main:] ~ [Controller 1]: Currently active brokers in
the cluster: Set() (KafkaController:68)
> 2016-04-05 11:01:54,952 INFO  - [main:] ~ [Controller 1]: Currently shutting brokers
in the cluster: Set() (KafkaController:68)
> 2016-04-05 11:01:54,952 INFO  - [main:] ~ [Controller 1]: Current list of topics in the
cluster: Set(ATLAS_ENTITIES, ATLAS_HOOK) (KafkaController:68)
> 2016-04-05 11:01:54,956 INFO  - [main:] ~ [Replica state machine on controller 1]: Started
replica state machine with initial state -> Map([Topic=ATLAS_ENTITIES,Partition=0,Replica=1]
-> ReplicaDeletionIneligible, [Topic=ATLAS_HOOK,Partition=0,Replica=1] -> ReplicaDeletionIneligible)
(ReplicaStateMachine:68)
> 2016-04-05 11:01:54,977 ERROR - [main:] ~ Controller 1 epoch 2 initiated state change
for partition [ATLAS_HOOK,0] from OfflinePartition to OnlinePartition failed (logger:103)
> kafka.common.NoReplicaOnlineException: No replica for partition [ATLAS_HOOK,0] is alive.
Live brokers are: [Set()], Assigned replicas are: [List(1)]
> 	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:75)
> 	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:345)
> 	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:205)
> 	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:120)
> 	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:117)
> 	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
> 	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:98)
> 	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:98)
> 	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:226)
> 	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39)
> 	at scala.collection.mutable.HashMap.foreach(HashMap.scala:98)
> 	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
> 	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:117)
> 	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:70)
> 	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:332)
> 	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:163)
> 	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:84)
> 	at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:50)
> 	at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:48)
> 	at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:48)
> 	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)
> 	at kafka.server.ZookeeperLeaderElector.startup(ZookeeperLeaderElector.scala:48)
> 	at kafka.controller.KafkaController$$anonfun$startup$1.apply$mcV$sp(KafkaController.scala:681)
> 	at kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:677)
> 	at kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:677)
> 	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)
> 	at kafka.controller.KafkaController.startup(KafkaController.scala:677)
> 	at kafka.server.KafkaServer.startup(KafkaServer.scala:188)
> 	at org.apache.atlas.kafka.KafkaNotification.startKafka(KafkaNotification.java:313)
> 	at org.apache.atlas.kafka.KafkaNotification.start(KafkaNotification.java:137)
> 	at org.apache.atlas.service.Services.start(Services.java:45)
> 	at org.apache.atlas.web.listeners.GuiceServletConfig.startServices(GuiceServletConfig.java:157)
> 	at org.apache.atlas.web.listeners.GuiceServletConfig.contextInitialized(GuiceServletConfig.java:151)
> 	at org.eclipse.jetty.server.handler.ContextHandler.callContextInitialized(ContextHandler.java:800)
> 	at org.eclipse.jetty.servlet.ServletContextHandler.callContextInitialized(ServletContextHandler.java:444)
> 	at org.eclipse.jetty.server.handler.ContextHandler.startContext(ContextHandler.java:791)
> 	at org.eclipse.jetty.servlet.ServletContextHandler.startContext(ServletContextHandler.java:294)
> 	at org.eclipse.jetty.webapp.WebAppContext.startWebapp(WebAppContext.java:1349)
> 	at org.eclipse.jetty.webapp.WebAppContext.startContext(WebAppContext.java:1342)
> 	at org.eclipse.jetty.server.handler.ContextHandler.doStart(ContextHandler.java:741)
> 	at org.eclipse.jetty.webapp.WebAppContext.doStart(WebAppContext.java:505)
> 	at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
> 	at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:132)
> 	at org.eclipse.jetty.server.Server.start(Server.java:387)
> 	at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:114)
> 	at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:61)
> 	at org.eclipse.jetty.server.Server.doStart(Server.java:354)
> 	at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
> 	at org.apache.atlas.web.service.EmbeddedServer.start(EmbeddedServer.java:93)
> 	at org.apache.atlas.Atlas.main(Atlas.java:109)
> 2016-04-05 11:01:54,991 ERROR - [main:] ~ Controller 1 epoch 2 initiated state change
for partition [ATLAS_ENTITIES,0] from OfflinePartition to OnlinePartition failed (logger:103)
> kafka.common.NoReplicaOnlineException: No replica for partition [ATLAS_ENTITIES,0] is
alive. Live brokers are: [Set()], Assigned replicas are: [List(1)]
> 	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:75)
> 	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:345)
> 	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:205)
> 	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:120)
> 	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:117)
> 	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
> 	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:98)
> 	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:98)
> 	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:226)
> 	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39)
> 	at scala.collection.mutable.HashMap.foreach(HashMap.scala:98)
> 	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
> 	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:117)
> 	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:70)
> 	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:332)
> 	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:163)
> 	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:84)
> 	at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:50)
> 	at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:48)
> 	at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:48)
> 	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)
> 	at kafka.server.ZookeeperLeaderElector.startup(ZookeeperLeaderElector.scala:48)
> 	at kafka.controller.KafkaController$$anonfun$startup$1.apply$mcV$sp(KafkaController.scala:681)
> 	at kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:677)
> 	at kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:677)
> 	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)
> 	at kafka.controller.KafkaController.startup(KafkaController.scala:677)
> 	at kafka.server.KafkaServer.startup(KafkaServer.scala:188)
> 	at org.apache.atlas.kafka.KafkaNotification.startKafka(KafkaNotification.java:313)
> 	at org.apache.atlas.kafka.KafkaNotification.start(KafkaNotification.java:137)
> 	at org.apache.atlas.service.Services.start(Services.java:45)
> 	at org.apache.atlas.web.listeners.GuiceServletConfig.startServices(GuiceServletConfig.java:157)
> 	at org.apache.atlas.web.listeners.GuiceServletConfig.contextInitialized(GuiceServletConfig.java:151)
> 	at org.eclipse.jetty.server.handler.ContextHandler.callContextInitialized(ContextHandler.java:800)
> 	at org.eclipse.jetty.servlet.ServletContextHandler.callContextInitialized(ServletContextHandler.java:444)
> 	at org.eclipse.jetty.server.handler.ContextHandler.startContext(ContextHandler.java:791)
> 	at org.eclipse.jetty.servlet.ServletContextHandler.startContext(ServletContextHandler.java:294)
> 	at org.eclipse.jetty.webapp.WebAppContext.startWebapp(WebAppContext.java:1349)
> 	at org.eclipse.jetty.webapp.WebAppContext.startContext(WebAppContext.java:1342)
> 	at org.eclipse.jetty.server.handler.ContextHandler.doStart(ContextHandler.java:741)
> 	at org.eclipse.jetty.webapp.WebAppContext.doStart(WebAppContext.java:505)
> 	at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
> 	at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:132)
> 	at org.eclipse.jetty.server.Server.start(Server.java:387)
> 	at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:114)
> 	at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:61)
> 	at org.eclipse.jetty.server.Server.doStart(Server.java:354)
> 	at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
> 	at org.apache.atlas.web.service.EmbeddedServer.start(EmbeddedServer.java:93)
> 	at org.apache.atlas.Atlas.main(Atlas.java:109)
> 2016-04-05 11:01:54,996 INFO  - [main:] ~ [Partition state machine on Controller 1]:
Started partition state machine with initial state -> Map([ATLAS_HOOK,0] -> OfflinePartition,
[ATLAS_ENTITIES,0] -> OfflinePartition) (PartitionStateMachine:68
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message