카산드라 업그레이드 0.8.2-> 0.8.4 오류 "모든 엔드 포인트 연결에 실패했습니다"

Question

카산드라를 0.8.2에서 0.8.4로 업그레이드 한 후이 오류가 발생했습니다 카산드라를 다시 시작하고 데이터를 제거한 후 아무 것도하지 않았습니다. 도움이됩니다. 클라우드에 6 개의 동일한 시스템이 있으며, 정상적으로 작동합니다. netstat을 만들면 포트 9160을 듣습니다. nodetool ... 6 개의 컴퓨터를 사용하여 응답합니다.

무엇이 문제 일 수 있습니까? ("주"java.io.IOException 상위 스레드에서

예외 : 입력을 가져올 수 없습니다 org.apache.hadoop에서 org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits에서 (ColumnFamilyInputFormat.java:157) 분할 org.apache.hadoop.mapred.JobClient.submitJobInternal (JobClient.java:779) 에서. : 432) 에서 org.apache.hadoop.mapreduce.Job.waitForCompletion (Job.java:447) 에서 WordCount.run (알 수없는 소스) 에서 org.apache.hadoop.util.ToolRunner.run (ToolRunner.java : 65) at WordCount.main (알 수없는 출처) 에 의해 발생 : 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이 : 모든 엔드 포인트 ( org.apache.cassandra.hadoop.ColumnFamilyInputFormat.access $ 200 org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits (ColumnFamilyInputFormat.java:234)에서 ColumnFamilyInputFormat.java을/98.188.69.242 를 SLAVE1에 연결 실패 : 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)

Answer 1

문제가 해결되었는지는 알 수 없습니다. 나는 너와 같은 문제 (너와 같은 구성)와 트라이를 만났어. 문제점 위치 :

공개 목록 호출() {... 예외 목록 토큰의 getSubSplits = (KEYSPACE, cfName, 범위의 conf)을 발생; ... 메소드 getSubSplits에서

방법을

(참 호스트 ConfigHelper.getRpcPort (conf의)) createConnection

호출, 호스트의 형식이 옳지 않다. 호스트 이름/10.197.34.111 가끔 (ip_address)이므로 createConnection이 실패합니다. IP 주소를 추출한 다음 createConnection을 호출해야합니다.

코드를 변경하고 Hadoop을 다시 시도 할 수 있습니다.

행운을 빈다.