/ / Грешка при създаване на таблица през java api в HBase - java, apache, hbase

Грешка при създаването на таблицата чрез java api в HBase - java, apache, hbase

Опитвам се да създам таблица в HBase чрез JAVA api. Моят код е следният:

Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "127.0.0.1");
config.set("hbase.client.retries.number", "1");
config.set("zookeeper.session.timeout", "40000");
config.set("zookeeper.recovery.retry", "1");

System.out.println("HBASE is running");
Connection conn = ConnectionFactory.createConnection(config);
Table table = conn.getTable(TableName.valueOf("recommendations"));
HTableDescriptor tableDescriptor = table.getTableDescriptor();
tableDescriptor.addFamily(new HColumnDescriptor("personal"));
tableDescriptor.addFamily(new HColumnDescriptor("professional"));
Admin admin = conn.getAdmin();
// Execute the table through admin
admin.createTable(tableDescriptor);

Грешката е както по-долу:

Причинено от:

org.apache.hadoop.hbase.MasterNotRunningException:
com.google.protobuf.ServiceException:
org.apache.hadoop.hbase.DoNotRetryIOException:
java.lang.NoSuchMethodError: org.apache.hadoop.net.NetUtils.getInputStream(Ljava/net/Socket;)Lorg/apache/hadoop/net/SocketInputWrapper;
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation$StubMaker.makeStub(ConnectionManager.java:1485)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation$MasterServiceStubMaker.makeStub(ConnectionManager.java:1505)
at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.getKeepAliveMasterService(ConnectionManager.java:1711)
at org.apache.hadoop.hbase.client.MasterCallable.prepare(MasterCallable.java:38)
at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithRetries(RpcRetryingCaller.java:124)

В състояние съм да създам таблица чрез обвивката на hbase. Всеки вход ще бъде оценен.

Отговори:

0 за отговор № 1

Изглежда HBase в ConnectionManager се опитва да използва метода SocketInputWrapper NetUtils#getInputStream(Socket) от Hadoop, но такъв метод не е намерен.

И така: класът съществува, но не разполага с този метод.

Много вероятно използвате някои класове HBase за Hadoop 1 и го използвате с Hadoop 2, или viceversa, или някои несъвместими версии.

Какви версии на Hadoop и HBase използвате? Какви версии на Hadoop и HBase използват обвивка на HBase?