apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From AJAY GUPTA <ajaygit...@gmail.com>
Subject Re: Hdfs + apex-core
Date Thu, 18 May 2017 12:09:28 GMT
Hi Rohit,

The conflict could also be with the version present in hadoop classpath.
If possible, send us the list of libraries in hadoop classpath and
the list of libraries used by the application at runtime ("hdfs dfs -ls
datatorrent/apps/<appid>" )

Ajay

On Thu, May 18, 2017 at 2:38 PM, AJAY GUPTA <ajaygit158@gmail.com> wrote:

> 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.garg41@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.closeRes
>> ponder(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/applicat
>> ion_1495028624385_0006/recovery/log
>> 2017-05-18
>> <http://10.139.39.54:9000/user/apex/datatorrent/apps/application_1495028624385_0006/recovery/log2017-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.
>>
>
>

Mime
View raw message