Skip to content

Instantly share code, notes, and snippets.

@Foolius
Created April 16, 2014 09:26
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Foolius/10840474 to your computer and use it in GitHub Desktop.
Save Foolius/10840474 to your computer and use it in GitHub Desktop.
Error of one Map
Node [10.10.1.1:9201] failed; selected next node [10.10.1.6:9201]
Node [10.10.1.6:9201] failed; selected next node [10.10.1.2:9201]
Node [10.10.1.2:9201] failed; selected next node [10.10.1.5:9201]
Node [10.10.1.5:9201] failed; selected next node [hadoop.kbs.uni-hannover.de:9200]
Node [hadoop.kbs.uni-hannover.de:9200] failed; selected next node [10.10.1.3:9201]
Node [10.10.1.3:9201] failed; selected next node [130.75.152.115:9200]
Node [130.75.152.115:9200] failed; selected next node [10.10.1.7:9201]
Node [10.10.1.7:9201] failed; selected next node [10.10.1.8:9201]
Node [10.10.1.8:9201] failed; selected next node [10.10.1.4:9201]
Node [10.10.1.4:9201] failed; no other nodes left - aborting...
Initializing logs' truncater with mapRetainSize=-1 and reduceRetainSize=-1
Error running child
org.elasticsearch.hadoop.rest.EsHadoopProtocolException: Connection error (check network and/or proxy settings) - out of nodes and retries
at org.elasticsearch.hadoop.rest.NetworkClient.execute(NetworkClient.java:96)
at org.elasticsearch.hadoop.rest.RestClient.execute(RestClient.java:275)
at org.elasticsearch.hadoop.rest.RestClient.execute(RestClient.java:271)
at org.elasticsearch.hadoop.rest.RestClient.bulk(RestClient.java:138)
at org.elasticsearch.hadoop.rest.RestRepository.sendBatch(RestRepository.java:163)
at org.elasticsearch.hadoop.rest.RestRepository.doWriteToIndex(RestRepository.java:146)
at org.elasticsearch.hadoop.rest.RestRepository.writeToIndex(RestRepository.java:124)
at org.elasticsearch.hadoop.mr.EsOutputFormat$EsRecordWriter.write(EsOutputFormat.java:160)
at org.elasticsearch.hadoop.pig.EsStorage.putNext(EsStorage.java:191)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat$PigRecordWriter.write(PigOutputFormat.java:139)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat$PigRecordWriter.write(PigOutputFormat.java:98)
at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.write(MapTask.java:558)
at org.apache.hadoop.mapreduce.task.TaskInputOutputContextImpl.write(TaskInputOutputContextImpl.java:85)
at org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.write(WrappedMapper.java:106)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapOnly$Map.collect(PigMapOnly.java:48)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.runPipeline(PigGenericMapBase.java:285)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:278)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:64)
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:140)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:672)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:330)
at org.apache.hadoop.mapred.Child$4.run(Child.java:268)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:415)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1408)
at org.apache.hadoop.mapred.Child.main(Child.java:262)
Caused by: java.net.SocketTimeoutException: Read timed out
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:150)
at java.net.SocketInputStream.read(SocketInputStream.java:121)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
at java.io.BufferedInputStream.read(BufferedInputStream.java:254)
at org.apache.commons.httpclient.HttpParser.readRawLine(HttpParser.java:78)
at org.apache.commons.httpclient.HttpParser.readLine(HttpParser.java:106)
at org.apache.commons.httpclient.HttpConnection.readLine(HttpConnection.java:1116)
at org.apache.commons.httpclient.HttpMethodBase.readStatusLine(HttpMethodBase.java:1973)
at org.apache.commons.httpclient.HttpMethodBase.readResponse(HttpMethodBase.java:1735)
at org.apache.commons.httpclient.HttpMethodBase.execute(HttpMethodBase.java:1098)
at org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:398)
at org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:171)
at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:323)
at org.elasticsearch.hadoop.rest.commonshttp.CommonsHttpTransport.execute(CommonsHttpTransport.java:298)
at org.elasticsearch.hadoop.rest.NetworkClient.execute(NetworkClient.java:80)
... 25 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment