Описание тега hbase-client

1 ответ

TableNotFoundException при обновлении клиента hbase с 0,98 до 1,1

Я только что перешел на HortonWorks HBase клиент 1.1.2.2.4.2.0-258 с версии 0.98. Все отлично работает локально, но через пару минут под рабочей нагрузкой у меня начинает появляться TableNotFoundException: Caused by: org.apache.hadoop.hbase.TableNot…
0 ответов

Сканирование больших таблиц из 130 миллионов строк выдает java.lang.IllegalStateException: не запущено

Попытка отсканировать Bigtable с 130 миллионами строк с помощью Java-клиента HBase. После нескольких часов сканирования он выдает: INFO com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation - Retrying failed call. Failure #1, got: Status{co…
1 ответ

Совместимость версий в Spark и Hbase-клиенте

Я пытаюсь написать пакетную работу Spark. Я хочу упаковать его в банку и использовать с искрой отправки. Моя программа прекрасно работает в spark-shell, однако я получаю следующую ошибку при попытке запустить ее с помощью spark submit: Exception in …
30 ноя '16 в 14:59
0 ответов

Постоянное число запросов HBase занимает почти ровно 5000 мс для успешного завершения, несмотря на меньшее время ожидания. Не знаю почему

Мой клиент использует org.apache.hbase:hbase-client:2.1.0" и сервер работает 1.2.0-cdh5.11.1 (1.2.0-cdh5.11.0 в альтернативном тестовом кластере). Мой клиент очень прост, он создает Connection класс при запуске (этот класс - в соответствии с рекомен…
12 фев '19 в 07:09
1 ответ

Слишком много подключений моего клиента hbase

Чтобы получить максимальную пропускную способность, я использую пакетные путы и приращения, чтобы поместить данные в hbase, пример кода: Configuration configuration = HBaseConfiguration.create(); configuration.set("hbase.zookeeper.quorum", "10.2.1.1…
04 июн '17 в 05:17
1 ответ

HBase BufferedMutator против производительности PutList

Недавно я наткнулся на класс HBase BufferedMutator, который можно использовать для пакетной вставки и удаления. Ранее я использовал список, чтобы поместить данные как hTable.put(putList) сделать то же самое. Сравнительный анализ моего кода, похоже, …
24 авг '17 в 15:21
1 ответ

API клиента Hbase не подключается к Hbase, создавая исключение SocketTimeoutException

Я пытаюсь подключиться к Hbase используя клиентский API Hbase в kerborized Кластер клоудера. Образец кода: Configuration hbaseConf = HBaseConfiguration.create(); /*hbaseConf.set("hbase.master", "somenode.net:2181"); hbaseConf.set("hbase.client.scann…
26 фев '18 в 15:48
1 ответ

Hbase rest api несколько вставок

Мы планируем использовать hbase rest api для выполнения вставок в таблицу hbase и хотели бы знать, есть ли способ вставить несколько столбцов в одно семейство столбцов или даже несколько семей столбцов за один вызов. Если нет, так как мы планируем в…
13 фев '19 в 19:32
1 ответ

Поиск префикса по определенному столбцу в hbase не работает в Java

Есть столбец, в котором указано, что в hbase указаны страны, и я хочу добавить к этому столбцу префикс (это не ключ строки), тогда я буду использовать ColumnPrefixFilter и сделаю что-то подобное ColumnPrefixFilter columnPrefixFilter = new ColumnPref…
30 окт '18 в 14:37
0 ответов

Как подключиться из проекта scala sbt к hbase, который находится за обратным прокси?

Я пытаюсь подключиться к hbase из проекта scala sbt. Hbase находится за обратным прокси. Прокси-сервер нуждается в аутентификации AD. Кто-нибудь может мне помочь? Возможно ли это с помощью клиентского API hbase?
23 май '18 в 09:04
1 ответ

Ошибка hbase-client 2.0.x

Я пытаюсь подключиться к удаленному серверу hbase, используя Java-клиент hbase-client. До сих пор я смог заставить его работать с hbase-client версии 1.3.1. Но чтобы разрешить конфликт зависимостей с помощью gRPC, я пытаюсь использовать версию hbase…
28 сен '17 в 11:51
1 ответ

Не удается получить доступ к базе данных HBase (которая работает на защищенном кластере) из Eclipse?

Попытка подключиться к HBase database из программы Eclipse Scala в Windows, Кластер secured using Kerberos Аутентификация, поэтому она не подключается к базе данных Hbase. Каждый раз, когда мы создаем файл jar и работаем в кластере. но это не полезн…
1 ответ

Не удается подключиться к BigTable с помощью фабрики соединений

Я использую пользовательский код для загрузки HFiles непосредственно в BigTable, используя следующие APILoadIncrementalHFiles loader = new LoadIncrementalHFiles(conf); loader.doBulkLoad(new Path(inputPath), admin, table, regionLocator);при использов…
05 июл '17 в 07:02
0 ответов

Hbase Rest API устанавливает свойства

Я использую конечную точку Hbase Rest для аутентификации и выполнения вставок, и в процессе мне нужно было бы установить свойство клиента как ("Hbase.client.keybakue.maxsize", "0"). Я могу сделать это с помощью Java / Scala. Кто-нибудь знает, если /…
18 фев '19 в 19:32
1 ответ

Hbase Table.batch занимает 300 секунд, чтобы вставить 800000 записей в таблицу

Я читаю файл json размером 30 Мб, процесс создания семейства столбцов и значения ключей. Затем создайте объект Put, вставьте в него ключ строки и значения. Создайте список таких помещаемых объектов и вызовите Table.batch() и передайте этот список. Я…
0 ответов

Как избежать прерывания InterExptedIOException в Hbase?

При вводе данных в Hbase, с использованием HTable.put метод, я буду в конечном итоге с приведенным ниже исключением иногда. Но данные на самом деле были записаны Hbase когда я проверил операцию получения для этого конкретного rowkey, В то же время я…
13 сен '18 в 10:47
1 ответ

Приведение к длинному типу данных - BigQuery

BigQuery и SQL нуб здесь. Я просматривал возможные типы данных, которые поддерживает большой запрос. У меня есть столбец в bigtable, который имеет тип bytes и его исходный тип данных является Scala Long, Это было преобразовано в bytes и хранится в b…
09 ноя '17 в 02:23
0 ответов

org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException: таблица семейства столбцов не существует в регионе hbase:meta

Я сталкиваюсь со странной ошибкой в ​​hbase. Когда я использую этот фильтр:- SingleColumnValueFilter Filter = new SingleColumnValueFilter(CF_NAME, QF_NAME, CompareOperator.GREATER_OR_EQUAL,new BinaryComparator(Bytes.toBytes(1539340372000L))) Это не …
1 ответ

Не удается подключиться к Bigtable для сканирования данных HTable из-за жестко запрограммированного управляемого =true в jar-клиенте hbase

Я работаю над пользовательской функцией загрузки для загрузки данных из Bigtable с помощью Pig на Dataproc. Я компилирую свой код Java, используя следующий список файлов JAR, которые я взял из Dataproc. Когда я запускаю следующий скрипт Pig, он терп…
0 ответов

Как получить максимальное или минимальное значение для столбца в Hbase с помощью API клиента Java Hbase?

Я работаю над профилированием Hbase в java, поэтому мне нужно получить максимальное и минимальное значение каждого столбца в таблице с помощью клиентского API HBase.
28 фев '20 в 15:39