2011-08-14 23 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。

祝你好運!

相關問題