Слишком много подключений моего клиента hbase
Чтобы получить максимальную пропускную способность, я использую пакетные путы и приращения, чтобы поместить данные в hbase, пример кода:
Configuration configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "10.2.1.12:2181");
configuration.set("hbase.zookeeper.znode.parent", "/hbase");
Connection connection = ConnectionFactory.createConnection(configuration);
Table table = null;
try {
table = connection.getTable(TableName.valueOf("test"));
Object[] results = new Object[incrementList.size()];
table.batch(incrementList, results);
for (Object result : results) {
if (null == result) {
failed++;
} else {
//System.out.println("Batch operation result: " + result);
}
}
System.out.println("Batch operation failed: " + failed);
} catch (Exception ex) {
throw new RPCCallException("Hbase put error: " + ex.getMessage(), ex);
} finally {
table.close();
}
connection.close();
Всего 233 соединения. и стек потоков:
Версия hbase-клиента:
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-client</artifactId>
<version>1.3.0</version>
</dependency>
1 ответ
Я обнаружил проблему, конфигурация пула потоков по умолчанию для соединения hbase по умолчанию: core = max = 256, поэтому число потоков увеличится до 256