Я использую версию hbase-клиента CDH5.16.1. У меня настроено задание MapReduce для чтения некоторых файлов avro и пакетной записи их содержимого в HBase.
Моя установка включает кворум Zookeeper, сервер HBase Thrift, один мастер HBase и группу RegionServers.
Эта пакетная запись работала при использовании hbase-client версии 0.98.6-CDH5.3.3. Теперь путь записи застрял при вызове функции Table.batch () (т.е. все работало до этого момента). Я посмотрел на реализацию, она выполняет обратный вызов AsyncFuture, не уверенный, где он застрял.
Просто для получения дополнительной информации подпись batch () выглядит следующим образом для интерфейса org.apache.hadoop.hbase.client.Table: Object[] batch(final List<? extends Row> actions) throws IOException, InterruptedException;
Я использую Cloudera, поэтому у меня есть доступ к ClouderaManager, а также к журналам в Zookeeper, Thrift server и HBase RegionServers, но я не вижу ничего связанного с этим вызовом в журнале. Не уверен, что это потому, что у меня не включен нужный уровень ведения журнала или на этих серверах ничего не получено. Может кто-нибудь дать несколько указателей?