Асинхронный клиент Aerospike часто закрывает и открывает соединения ⇐ JAVA

[Anonymous]

У нас есть приложение flink, в котором мы записываем данные в aerospike. Мы используем асинхронный клиентский вызов aerospike для записи данных в aerospike. Изменения работали нормально, но один из показателей не подходил для подключений каждого пользователя. Поскольку изменения теперь асинхронны, мы видим более частые колебания количества клиентских подключений по пользовательским показателям.
Код клиента:

Код: Выделить всё

@Provides
@Singleton
public AerospikeClient aerospikeClient() {
ClientPolicy policy = new ClientPolicy();
EventPolicy eventPolicy = new EventPolicy();
int eventLoopSize = Runtime.getRuntime().availableProcessors() / 2;
EventLoops eventLoops = new NioEventLoops(eventPolicy, eventLoopSize);
policy.timeout = aerospikeConfig.getTimeout();
policy.user = aerospikeConfig.getUser();
policy.password = aerospikeConfig.getPassword();
policy.eventLoops = eventLoops;
return new AerospikeClient(policy, aerospikeConfig.getHost(), aerospikeConfig.getPort());
}

Что еще мы можем добавить, чтобы стабилизировать соединения?
При необходимости используйте цифры, чтобы установить значения.
параллелизм flink: x
рабочие узлы flink : y
узлы aerospike: z
Клиент Aerospike: NA и EU
Мы думали о внедрении AsyncMinConnectionPerNode, но все же могли возникнуть некоторые колебания даже после увеличения его при локальной настройке.< /п>

Подробнее здесь: https://stackoverflow.com/questions/790 ... frequently