Hi Rohit, It seems there is a dependency conflict for one of the libraries httpclient. Can you send us the output of mvn dependency:tree for your application?
Also, it would be great if we could also receive the application master logs. You can find them at <hadoop-log-dir>/userlogs/<application-id> . You could zip and the logs. Ajay On Thu, May 18, 2017 at 11:33 AM, userguy <rohit.gar...@gmail.com> wrote: > How does -- Locality Affects the Error while submitting Job in YARN > > for cluster com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, > kafka partition 28 > 2017-05-18 11:25:46,680 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 29 > 2017-05-18 11:25:46,682 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 30 > 2017-05-18 11:25:46,684 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 31 > 2017-05-18 11:25:46,686 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 32 > 2017-05-18 11:25:46,688 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 33 > 2017-05-18 11:25:46,690 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 34 > 2017-05-18 11:25:46,691 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 35 > 2017-05-18 11:25:46,693 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 36 > 2017-05-18 11:25:46,695 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 37 > 2017-05-18 11:25:46,696 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 38 > 2017-05-18 11:25:46,698 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 39 > 2017-05-18 11:25:46,700 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 40 > 2017-05-18 11:25:46,702 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 41 > 2017-05-18 11:25:46,704 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 42 > 2017-05-18 11:25:46,706 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 43 > 2017-05-18 11:25:46,713 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 44 > 2017-05-18 11:25:46,715 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 45 > 2017-05-18 11:25:46,716 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 46 > 2017-05-18 11:25:46,718 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 47 > 2017-05-18 11:25:46,720 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 48 > 2017-05-18 11:25:46,722 INFO [main] kafka.AbstractKafkaInputOperator > (AbstractKafkaInputOperator.java:definePartitions(548)) - [ONE_TO_ONE]: > Create operator partition for cluster > com.datatorrent.contrib.kafka.defaultcluster, topic jiovodems, kafka > partition 49 > 2017-05-18 11:25:46,813 INFO [main] util.AsyncFSStorageAgent > (AsyncFSStorageAgent.java:save(91)) - using > /var/data/yarn/local/usercache/apex/appcache/application_1495028624385_ > 0006/container_1495028624385_0006_02_000001/tmp/chkp8177464469451000346 > as the basepath for checkpointing. > 2017-05-18 11:25:47,459 WARN [DataStreamer for file > /user/apex/datatorrent/apps/application_1495028624385_ > 0006/checkpoints/8/_tmp] > hdfs.DFSClient (DFSOutputStream.java:closeResponder(953)) - Caught > exception > java.lang.InterruptedException > at java.lang.Object.wait(Native Method) > at java.lang.Thread.join(Thread.java:1245) > at java.lang.Thread.join(Thread.java:1319) > at > org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer.closeResponder( > DFSOutputStream.java:951) > at > org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer. > endBlock(DFSOutputStream.java:689) > at > org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer. > run(DFSOutputStream.java:878) > 2017-05-18 11:25:49,615 INFO [main] stram.FSRecoveryHandler > (FSRecoveryHandler.java:rotateLog(103)) - Creating > hdfs://10.139.39.54:9000/user/apex/datatorrent/apps/ > application_1495028624385_0006/recovery/log > 2017-05-18 11:25:49,669 INFO [main] stram.StreamingAppMasterService > (StreamingAppMasterService.java:serviceInit(564)) - Starting application > with 55 operators in 54 containers > 2017-05-18 11:25:49,686 INFO [main] impl.NMClientAsyncImpl > (NMClientAsyncImpl.java:serviceInit(107)) - Upper bound of the thread pool > size is 500 > 2017-05-18 11:25:49,722 INFO [main] loaders.ChainedPluginLocator > (ChainedPluginLocator.java:discoverPlugins(54)) - Loader > org.apache.apex.engine.plugin.loaders.ServiceLoaderBasedPluginLocator > detected 0 plugins > 2017-05-18 11:25:49,758 WARN [main] conf.Configuration > (Configuration.java:loadProperty(2681)) - > org.apache.hadoop.hdfs.client.HdfsDataInputStream@3d798e76: > org.apache.hadoop.hdfs.DFSInputStream@763b0996:an attempt to override > final > parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring. > 2017-05-18 11:25:49,760 WARN [main] conf.Configuration > (Configuration.java:loadProperty(2681)) - > org.apache.hadoop.hdfs.client.HdfsDataInputStream@3d798e76: > org.apache.hadoop.hdfs.DFSInputStream@763b0996:an attempt to override > final > parameter: mapreduce.job.end-notification.max.attempts; Ignoring. > 2017-05-18 11:25:49,761 INFO [main] loaders.ChainedPluginLocator > (ChainedPluginLocator.java:discoverPlugins(54)) - Loader > org.apache.apex.engine.plugin.loaders.PropertyBasedPluginLocator detected > 0 > plugins > 2017-05-18 11:25:49,769 INFO [main] client.RMProxy > (RMProxy.java:createRMProxy(123)) - Connecting to ResourceManager at > /0.0.0.0:8030 > 2017-05-18 11:25:49,814 INFO [main] stram.StreamingContainerParent > (StreamingContainerParent.java:startRpcServer(95)) - Config: > Configuration: > core-default.xml, core-site.xml, yarn-default.xml, yarn-site.xml, > mapred-default.xml, mapred-site.xml, hdfs-default.xml, hdfs-site.xml > 2017-05-18 11:25:49,815 INFO [main] stram.StreamingContainerParent > (StreamingContainerParent.java:startRpcServer(96)) - Listener thread count > 30 > 2017-05-18 11:25:49,819 INFO [main] ipc.CallQueueManager > (CallQueueManager.java:<init>(57)) - Using callQueue: class > java.util.concurrent.LinkedBlockingQueue queueCapacity: 3000 > 2017-05-18 11:25:49,824 INFO [Socket Reader #1 for port 33999] ipc.Server > (Server.java:run(720)) - Starting Socket Reader #1 for port 33999 > 2017-05-18 11:25:49,837 INFO [IPC Server listener on 33999] ipc.Server > (Server.java:run(799)) - IPC Server listener on 33999: starting > 2017-05-18 11:25:49,837 INFO [IPC Server Responder] ipc.Server > (Server.java:run(952)) - IPC Server Responder: starting > 2017-05-18 11:25:49,841 INFO [main] stram.StreamingContainerParent > (StreamingContainerParent.java:startRpcServer(124)) - Container callback > server listening at ELKCDNHOST9/10.139.38.180:33999 > 2017-05-18 11:25:49,880 INFO [main] mortbay.log (Slf4jLog.java:info(67)) - > Logging to org.slf4j.impl.Log4jLoggerAdapter(org.mortbay.log) via > org.mortbay.log.Slf4jLog > 2017-05-18 11:25:49,958 INFO [main] server.AuthenticationFilter > (AuthenticationFilter.java:constructSecretProvider(294)) - Unable to > initialize FileSignerSecretProvider, falling back to use random secrets. > 2017-05-18 11:25:49,966 INFO [main] http.HttpRequestLog > (HttpRequestLog.java:getRequestLog(80)) - Http request log for > http.requests.stram is not defined > 2017-05-18 11:25:49,979 INFO [main] http.HttpServer2 > (HttpServer2.java:addGlobalFilter(766)) - Added global filter 'safety' > (class=org.apache.hadoop.http.HttpServer2$QuotingInputFilter) > 2017-05-18 11:25:49,981 INFO [main] http.HttpServer2 > (HttpServer2.java:addFilter(744)) - Added filter static_user_filter > (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to > context stram > 2017-05-18 11:25:49,981 INFO [main] http.HttpServer2 > (HttpServer2.java:addFilter(751)) - Added filter static_user_filter > (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to > context logs > 2017-05-18 11:25:49,981 INFO [main] http.HttpServer2 > (HttpServer2.java:addFilter(751)) - Added filter static_user_filter > (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to > context static > 2017-05-18 11:25:49,989 INFO [main] http.HttpServer2 > (HttpServer2.java:initializeWebServer(443)) - adding path spec: /stram/* > 2017-05-18 11:25:49,989 INFO [main] http.HttpServer2 > (HttpServer2.java:initializeWebServer(443)) - adding path spec: /ws/* > 2017-05-18 11:25:49,997 INFO [main] http.HttpServer2 > (HttpServer2.java:openListeners(954)) - Jetty bound to port 54855 > 2017-05-18 11:25:50,372 INFO [main] webapp.WebApps > (WebApps.java:start(275)) - Web app /stram started at 54855 > 2017-05-18 11:25:50,710 INFO [main] webapp.WebApps > (WebApps.java:start(289)) - Registered webapp guice modules > 2017-05-18 11:25:50,711 INFO [main] stram.StreamingAppMasterService > (StreamingAppMasterService.java:serviceStart(635)) - Started web service > at > port: 54855 > 2017-05-18 11:25:50,711 INFO [main] stram.StreamingAppMasterService > (StreamingAppMasterService.java:serviceStart(641)) - Setting tracking URL > to: ELKCDNHOST9:54855 > 2017-05-18 11:25:50,721 INFO [main] stram.StreamingAppMasterService > (StreamingAppMasterService.java:execute(685)) - Starting ApplicationMaster > 2017-05-18 11:25:50,721 INFO [main] stram.StreamingAppMasterService > (StreamingAppMasterService.java:execute(687)) - number of tokens: 1 > > > 2017-05-18 11:28:32,814 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 1 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:33,815 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 2 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:34,817 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 3 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:35,818 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 4 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:36,819 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 5 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:37,821 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 6 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:38,822 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 7 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:39,823 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 8 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:28:40,825 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 9 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:11,829 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 0 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:12,830 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 1 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:13,832 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 2 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:14,833 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 3 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:15,834 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 4 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:16,835 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 5 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:17,837 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 6 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:18,839 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 7 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:19,840 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 8 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:20,841 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 9 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:51,845 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 0 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:52,847 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 1 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:53,848 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 2 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:54,849 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 3 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:55,851 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 4 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:56,852 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 5 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:57,853 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 6 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:58,855 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 7 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:29:59,856 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 8 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:00,858 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 9 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:31,861 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 0 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:32,863 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 1 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:33,864 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 2 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:34,866 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 3 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:35,867 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 4 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:36,869 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 5 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > 2017-05-18 11:30:37,870 INFO [main] ipc.Client > (Client.java:handleConnectionFailure(868)) - Retrying connect to server: > 0.0.0.0/0.0.0.0:8030. Already tried 6 time(s); retry policy is > RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 > MILLISECONDS) > > > > > -- > View this message in context: http://apache-apex-users-list. > 78494.x6.nabble.com/Fwd-Hdfs-apex-core-tp1608p1632.html > Sent from the Apache Apex Users list mailing list archive at Nabble.com. >
