Проблема при использовании java-клиента hbase при отправке данных в базу данных

Я тестирую hbase. Я использую автономный без hadoop. Я использовал версию hbase 0.90.6, код работал нормально, и я обновился до последней версии 0.94.0, и это исключение, пока я пытаюсь помещать данные в таблицу. ИсключениеПроблема при использовании java-клиента hbase при отправке данных в базу данных

Exception in thread "main" org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException: Failed 1 action: DoNotRetryIOException: 1 time, servers with issues: xxxx:36601, 
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processBatchCallback(HConnectionManager.java:1591) 
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processBatch(HConnectionManager.java:1367) 
    at org.apache.hadoop.hbase.client.HTable.flushCommits(HTable.java:945) 
    at org.apache.hadoop.hbase.client.HTable.doPut(HTable.java:801) 
    at org.apache.hadoop.hbase.client.HTable.put(HTable.java:776) 
    at com.hhase.Hbase.main(Hbase.java:22)

Я использую следующий код.

package com.hhase; 
import java.io.IOException; 

import org.apache.hadoop.conf.Configuration; 
import org.apache.hadoop.hbase.HBaseConfiguration; 
import org.apache.hadoop.hbase.client.Get; 
import org.apache.hadoop.hbase.client.HTable; 
import org.apache.hadoop.hbase.client.Put; 
import org.apache.hadoop.hbase.util.Bytes; 

public class Hbase { 

    public static void main(String args[]) throws IOException { 

     Configuration hConf = HBaseConfiguration.create(); 
     HTable table = new HTable(hConf, "myLittleHBaseTable"); 
     Put p = new Put(Bytes.toBytes("myLittleRow")); 

     Put put = new Put(Bytes.toBytes("myLittleRow")); 
     put.add(Bytes.toBytes("myLittleFamily"), 
       Bytes.toBytes("someQualifier"), Bytes.toBytes("Some")); 
     table.put(put); 


    } 
}

Библиотека используется

commons-cli-1.2.jar   hadoop-core-1.0.2.jar 
commons-codec-1.4.jar   hbase-0.94.0.jar 
commons-collections-3.2.1.jar httpclient-4.1.2.jar 
commons-configuration-1.6.jar httpcore-4.1.4.jar 
commons-httpclient-3.1.jar  log4j-1.2.16.jar 
commons-io-2.1.jar    protobuf-java-2.4.0a.jar 
commons-lang-2.5.jar   slf4j-api-1.5.8.jar 
commons-logging-1.1.1.jar  slf4j-log4j12-1.5.8.jar 
commons-net-1.4.1.jar   stax-api-1.0.1.jar 
guava-r09.jar     zookeeper-3.4.3.jar

источник

2012-06-15 Ramesh

установить конфигурационный файл ur в конфигурацию hConf = HBaseConfiguration.create(); conf.set ("hbase.zookeeper.quorum", "xxx.xx.xxxx"); conf.set ("hbase.zookeeper.property.clientPort", "xxxx"); – Navyah

я столкнулся с той же ошибки при вставке данных в HBase. В моем случае это произошло из-за неправильного имени фамилии столбца.

См. this conversation.

источник

2012-10-04 09:42:51

Хотя это теоретически может ответить на вопрос, [было бы предпочтительнее] (// meta.stackoverflow.com/q/8259) включить сюда основные части ответа и предоставить ссылку для справки. – slm

Проблема при использовании java-клиента hbase при отправке данных в базу данных

ответ

Смежные вопросы