Hi, Can you mention Apex version & check health status of NN?
Thanks, A _____________________________________ Sent with difficulty, I mean handheld ;) On 12 Apr 2017 12:43 pm, "rishi" <[email protected]> wrote: > Hi, > > I have been using apex application for [consuming messages from kafka, > parsing & writing it to HDFS].I want my application to run continuously. > But > due to some or the other error[error pasted below] it is failing.Please > have > a look at those errors and let me know if I could do something to avoid > application failure. > > *Error Messages captured from logs*:- > 2017-04-11 09:07:27,718 INFO hdfs.DFSClient > (DFSClient.java:getDelegationToken(1043)) - Created HDFS_DELEGATION_TOKEN > token 5971093 for ABCDEF on ha-hdfs:ldns > 2017-04-11 09:07:27,725 WARN ipc.Client > (Client.java:handleConnectionFailure(886)) - Failed to connect to server: > ........: retries get failed due to exceeded maximum allowed retries > number: > 0 > java.net.ConnectException: Connection refused > > > 2017-04-11 09:17:55,276 INFO retry.RetryInvocationHandler > (RetryInvocationHandler.java:log(267)) - Exception while invoking > ClientNamenodeProtocolTranslatorPB.renewLease over ....../....... Trying > to > failover immediately. > org.apache.hadoop.ipc.RemoteException(org.apache. > hadoop.ipc.StandbyException): > Operation category WRITE is not supported in state standby > > 2017-04-11 09:24:10,629 ERROR stram.FSEventRecorder > (FSEventRecorder.java:run(85)) - Caught Exception > java.io.IOException: Connection is not open > at > com.datatorrent.stram.util.PubSubWebSocketClient.assertUsable( > PubSubWebSocketClient.java:264) > at > com.datatorrent.stram.util.PubSubWebSocketClient.publish( > PubSubWebSocketClient.java:287) > at > com.datatorrent.stram.util.SharedPubSubWebSocketClient.publish( > SharedPubSubWebSocketClient.java:120) > at > com.datatorrent.stram.FSEventRecorder$EventRecorderThread.run( > FSEventRecorder.java:79) > > > 2017-04-11 09:24:19,636 ERROR stram.FSEventRecorder > (FSEventRecorder.java:run(85)) - Caught Exception > java.net.ConnectException: Connection refused: /21.12.12.12:9090 > at > org.apache.apex.shaded.ning19.com.ning.http.client. > providers.netty.request.NettyConnectListener.onFutureFailure( > NettyConnectListener.java:133) > at > org.apache.apex.shaded.ning19.com.ning.http.client. > providers.netty.request.NettyConnectListener.operationComplete( > NettyConnectListener.java:145) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > DefaultChannelFuture.notifyListener(DefaultChannelFuture.java:409) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > DefaultChannelFuture.notifyListeners(DefaultChannelFuture.java:400) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > DefaultChannelFuture.setFailure(DefaultChannelFuture.java:362) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:109) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > socket.nio.NioClientBoss.process(NioClientBoss.java:79) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel.socket.nio. > AbstractNioSelector.run(AbstractNioSelector.java:337) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > socket.nio.NioClientBoss.run(NioClientBoss.java:42) > at > org.apache.apex.shaded.ning19.org.jboss.netty.util. > ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) > at > org.apache.apex.shaded.ning19.org.jboss.netty.util.internal. > DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) > at > java.util.concurrent.ThreadPoolExecutor.runWorker( > ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run( > ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.net.ConnectException: Connection refused: / > 10.66.18.168:9090 > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > at sun.nio.ch.SocketChannelImpl.finishConnect( > SocketChannelImpl.java:717) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > socket.nio.NioClientBoss.connect(NioClientBoss.java:152) > at > org.apache.apex.shaded.ning19.org.jboss.netty.channel. > socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105) > ... 8 more > > > Thanks > Rishi > > > > > -- > View this message in context: http://apache-apex-users-list. > 78494.x6.nabble.com/Apex-application-getting-killed-at- > regular-interval-tp1512.html > Sent from the Apache Apex Users list mailing list archive at Nabble.com. >
