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.
