Ayub Khan created ATLAS-227: ------------------------------- Summary: Failing to start Embedded kafka should stop Atlas from starting Key: ATLAS-227 URL: https://issues.apache.org/jira/browse/ATLAS-227 Project: Atlas Issue Type: Bug Affects Versions: 0.6-incubating Reporter: Ayub Khan
While starting Atlas, If embedded kafka fails to start, make sure to exit/stop Atlas from coming up.. Issue: Currently Atlas comes up even when embedded kafka fails to start. Steps to reproduce: 1. Start Atlas as usual 2. Remove atlas.pid file from ATLAS_HOME/atlas.pid 3. Start Atlas again with usual command. Atlas starts but embedded kafka fails to start. One way stop this would be to check if ATLAS is already running using port scan. Attaching complete log file for debugging.. Application log snapshot: {code} 2015-10-14 10:53:05,727 INFO - [main:] ~ Logged in user apathan (auth:SIMPLE) (LoginProcessor:77) 2015-10-14 10:53:05,727 DEBUG - [main:] ~ Starting services (GuiceServletConfig:121) 2015-10-14 10:53:05,733 DEBUG - [main:] ~ Starting service org.apache.atlas.kafka.KafkaNotification (Services:45) 2015-10-14 10:53:05,733 DEBUG - [main:] ~ Starting zookeeper at localhost:9026 (KafkaNotification:137) 2015-10-14 10:53:05,740 INFO - [main:] ~ binding to port localhost/127.0.0.1:9026 (NIOServerCnxnFactory:94) 2015-10-14 10:53:05,740 WARN - [main:] ~ Failed startup of context o.e.j.w.WebAppContext@486afa2d{/,file:/usr/local/Cellar/atlas-master/apache-atlas-0.6-incubating-SNAPSHOT/server/webapp/atlas/,STARTING}{/usr/local/Cellar/atlas-master/apache-atlas-0.6-incubating-SNAPSHOT/server/webapp/atlas} (WebAppContext:514) java.lang.RuntimeException: org.apache.atlas.AtlasException: Failed to start embedded kafka at org.apache.atlas.service.Services.start(Services.java:49) at org.apache.atlas.web.listeners.GuiceServletConfig.startServices(GuiceServletConfig.java:123) at org.apache.atlas.web.listeners.GuiceServletConfig.contextInitialized(GuiceServletConfig.java:117) 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:88) at org.apache.atlas.Main.main(Main.java:106) Caused by: org.apache.atlas.AtlasException: Failed to start embedded kafka at org.apache.atlas.kafka.KafkaNotification.start(KafkaNotification.java:173) at org.apache.atlas.service.Services.start(Services.java:46) ... 19 more Caused by: java.net.BindException: Address already in use at sun.nio.ch.Net.bind0(Native Method) at sun.nio.ch.Net.bind(Net.java:444) at sun.nio.ch.Net.bind(Net.java:436) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:214) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67) at org.apache.zookeeper.server.NIOServerCnxnFactory.configure(NIOServerCnxnFactory.java:95) at org.apache.zookeeper.server.ServerCnxnFactory.createFactory(ServerCnxnFactory.java:126) at org.apache.atlas.kafka.KafkaNotification.startZk(KafkaNotification.java:140) at org.apache.atlas.kafka.KafkaNotification.start(KafkaNotification.java:170) ... 20 more 2015-10-14 10:53:05,745 INFO - [main:] ~ Started ServerConnector@3a55abab{HTTP/1.1}{0.0.0.0:21000} (ServerConnector:266) 2015-10-14 10:53:05,745 INFO - [main:] ~ Started @5484ms (Server:379) {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)