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