-
-
Save Foolius/10840474 to your computer and use it in GitHub Desktop.
Error of one Map
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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