Cassandra Upgrade 0.8.2-> 0.8.4 выдает ошибку «не удалось подключиться ко всем конечным точкам» - PullRequest
Новая
       25

Cassandra Upgrade 0.8.2-> 0.8.4 выдает ошибку «не удалось подключиться ко всем конечным точкам»

1 голос
/ 15 августа 2011

После обновления cassandra с 0.8.2 до 0.8.4, появилась эта ошибка Я перезапустил Кассандру, удалил данные и т. Д. Ничего не помогает У меня есть 6 идентичных машин в облаке, прежде чем он работал нормально. Если я делаю netstat, то показывает порт 9160 прослушивания nodetool ... ring - отвечает 6 машинами UP.

в чем может быть проблема? : (

Исключение в потоке "main" java.io.IOException: Не удалось получить входные разбиения в org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits (ColumnFamilyInputFormat.java:157) в org.apache.hadoop.mapred.JobClient.writeNewSplits (JobClient.java:885) в org.apache.hadoop.mapred.JobClient.submitJobInternal (JobClient.java:779) в org.apache.hadoop.mapreduce.Job.submit (Job.java:432) в org.apache.hadoop.mapreduce.Job.waitForCompletion (Job.java:447) на WordCount.run (неизвестный источник) в org.apache.hadoop.util.ToolRunner.run (ToolRunner.java:65) на WordCount.main (неизвестный источник) Вызвано: java.util.concurrent.ExecutionException: java.io.IOException: не удалось подключиться ко всем конечным точкам slave1 / 98.188.69.242 в java.util.concurrent.FutureTask $ Sync.innerGet (FutureTask.java:222) в java.util.concurrent.FutureTask.get (FutureTask.java:83) в 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) в org.apache.cassandra.hadoop.ColumnFamilyInputFormat $ SplitCallable.call (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) в java.util.concurrent.ThreadPoolExecutor $ Worker.runTask (ThreadPoolExecutor.java:886) в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:908) at java.lang.Thread.run (Thread.java:662)

1 Ответ

1 голос
/ 08 сентября 2011

Я не знаю, решили ли вы проблему. Я столкнулся с той же проблемой, что и ваша (та же конфигурация, что и у вас), и попытался ее решить. Проблемное место:

public List call () выдает Exception {... List tokens = getSubSplits (пространство ключей, cfName, range, conf); ...

В методе getSubSplits при вызове метода

createConnection (host, ConfigHelper.getRpcPort (conf), true)

, формат хоста не правильный. Иногда это hostname / 10.197.34.111 (ip_address), поэтому createConnection завершится ошибкой. Нам нужно извлечь IP-адрес, а затем вызвать createConnection.

Вы можете попробовать изменить код и снова попробовать Hadoop.

Удачи!

...