Could not get input splits Caused by: java.io.IOException: failed connecting to
all endpoints slave1/123.198.69.242
-------------------------------------------------------------------------------------------------------------------
Key: CASSANDRA-3037
URL: https://issues.apache.org/jira/browse/CASSANDRA-3037
Project: Cassandra
Issue Type: Bug
Components: Hadoop
Affects Versions: 0.8.4
Environment: Ubuntu 10.04 LTS
Hadoop from Cloudera 0.20.203
Latest java
Reporter: Anton Vedeshin
Priority: Blocker
After upgrade of cassandra from 0.8.2 to 0.8.4, got this error, before upgrade
everything was working fine
I have restarted cassandra, removed data, etc. nothing helps
I have 6 identical machines in the cloud, before it was working fine. If I make
netstat then it shows port 9160 listening nodetool ... ring - responces with 6
machines UP.
Finally I have truncated all 6 servers and reinstalled hadoop + cassandra 0.8.4
from scratch.
compiled and tried to execute word_cound
receive the same error as after upgrade
Error:
11/08/15 15:23:54 INFO WordCount: output reducer type: cassandra
11/08/15 15:23:54 INFO jvm.JvmMetrics: Initializing JVM Metrics with
processName=JobTracker, sessionId=
Exception in thread "main" java.io.IOException: Could not get input splits
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(ColumnFamilyInputFormat.java:157)
at org.apache.hadoop.mapred.JobClient.writeNewSplits(JobClient.java:885)
at
org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:779)
at org.apache.hadoop.mapreduce.Job.submit(Job.java:432)
at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:447)
at WordCount.run(Unknown Source)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
at WordCount.main(Unknown Source)
Caused by: java.util.concurrent.ExecutionException: java.io.IOException: failed
connecting to all endpoints slave1/154.198.69.242
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(ColumnFamilyInputFormat.java:153)
... 7 more
Caused by: java.io.IOException: failed connecting to all endpoints
slave1/154.198.69.242
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits(ColumnFamilyInputFormat.java:234)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.access$200(ColumnFamilyInputFormat.java:70)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat$SplitCallable.call(ColumnFamilyInputFormat.java:190)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat$SplitCallable.call(ColumnFamilyInputFormat.java:175)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
