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