2011-08-14 27 views
1

cassandra从0.8.2升级到0.8.4后,得到这个错误 我重新启动了cassandra,删除了数据等等。帮助 我有6个相同的机器在云端,它工作正常之前。 如果我使用netstat,那么它会显示端口9160正在监听 nodetool ... ring - 使用6台机器进行响应。Cassandra升级0.8.2-> 0.8.4得到错误“连接到所有终端失败”

可能是什么问题? (

异常线程 “main” 产生java.io.IOException:无法获取输入处分割org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits (ColumnFamilyInputFormat.java:157) 在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.util.ToolRunner.run(ToolRunner.java:org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:447) at WordCount.run(Unknown Source) 65) at WordCount.main(Unknown Source) 由于:java.util.concurrent.ExecutionException:java.io.IOException:未能连接到所有端点slave1/98.188.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更多 引起来自:java.io. IOException异常:无法连接到所有端点SLAVE1/98.188.69.242 在org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits(ColumnFamilyInputFormat.java:234) 在org.apache.cassandra.hadoop.ColumnFamilyInputFormat.access $ 200(ColumnFamilyInputFormat.java :70) at org.apache.cassandra.hadoop.ColumnFamilyInputFormat $ SplitCallable。调用(ColumnFamilyInputFormat.java:190) 在org.apache.cassandra.hadoop.ColumnFamilyInputFormat $ SplitCallable.call(ColumnFamilyInputFormat.java:175) 在java.util.concurrent.FutureTask中$ Sync.innerRun(FutureTask.java:303) (java.util.concurrent.FutureTask.run)(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor $ Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor $ Worker。运行(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662)

+0

你做了什么故障排除? – jbellis

回答

1

我不知道你是否已经解决了这个问题。我遇到了和你一样的问题(与你的配置相同),并解决它。 问题的位置:

公共列表()调用抛出异常{...列表 令牌= getSubSplits(密钥空间,cfName,范围,CONF); ...

在方法调用getSubSplits方法

的createConnection(主机,ConfigHelper.getRpcPort(CONF),真)

时,主机的格式不正确。它有时候是hostname/10.197.34.111(ip_address),所以createConnection会失败。我们需要提取IP地址,然后调用createConnection。

您可以尝试更改代码并再次尝试Hadoop。

祝你好运!

相关问题