Вопросы по теме 'accumulo'

ThriftSecurityException (пользователь: root, код: BAD_CREDENTIALS)
Когда я пытаюсь подключиться к accumulo из java-клиента, это не удается. Я использую пользователя «root», но изменил пароль. Я отладил свой код, на самом деле он получает правильное имя пользователя и пароль, те же самые, которые я использую для...
1519 просмотров
schedule 27.11.2022

Spark с HDFS на входе и Accumulo на выходе
Я собираюсь реализовать систему с использованием HDFS и Accumulo. У меня есть несколько файлов в моей HDFS, и мне нужно обработать их с помощью задания Spark и сохранить в Accumulo. Я не мог найти хороших примеров с помощью Google. Может ли...
528 просмотров
schedule 11.11.2022

Как удалить записи в Accumulo на основе rowkey через прокси-клиент Accumulo
Я использую Accumulo 1.6 и хочу удалить некоторые записи, указав ключ строки через прокси-клиент accumulo в nodejs. но прокси-клиент выдает «начальная строка должна быть меньше конечной строки», когда я пытаюсь поместить тот же ключ строки в API...
304 просмотров
schedule 30.05.2024

Перестроить Accumulo после того, как сбой namenode повредит корневой блок
в нашем разрабатываемом кластере HDP произошло отключение питания, которое повредило некоторые системные блоки HDFS, используемые Accumulo, теперь кластер находится в безопасном режиме, и ambari не перезапускается. Будучи коробкой DEV, HDFS имеет...
157 просмотров

Использование Accumulo в качестве источника и приемника на Flink
Я хотел бы использовать Apache Accumulo для хранения данных о событиях и выполнения некоторых вычислений с помощью Apache Flink. Я знаю, что это можно сделать с помощью Apache Spark, прочитать некоторые записи из Accumulo как RDD Чтение из...
182 просмотров
schedule 13.12.2023

Как получить таблицу репликации в accumulo
При вводе данных в Accumulo он зависает. Ниже приведены логи с главного сервера. [tableOps.Utils] ИНФОРМАЦИЯ: таблица !0 (60b7e8cebdb385a4) заблокирована для операции чтения: COMPACT [tableOps.CompactRange] ИНФОРМАЦИЯ: нет итераторов или...
274 просмотров
schedule 07.01.2024

Использование GeoMesa Native API для вставки данных в накопление
Я пытаюсь вставить и прочитать данные из накопительного хранилища, используя GeoMesa Native API . Я создал файл класса, чтобы изначально использовать хранилище Geomesa accumulo. Вот мой код Java: package org.locationtech.geomesa.api; import...
606 просмотров
schedule 05.12.2023