начали переводить абонентов в новый билинг . как я понимаю проблема с worker
взял с документации (изменил thread.count) Пример конфигурации с несколькими обработчиками тарификации (для более частой тарификации соединений с бОльшим трафиком):
ошибка стала появляться реже, но все же.
Код:
# Количество потоков на worker
accounting.worker.1.thread.count=3
# Тарификатор:
accounting.worker.1.tariffication.1.minDeltaAmount=104857600
accounting.worker.1.tariffication.1.delay=10
accounting.worker.1.tariffication.1.batchSize=1000
accounting.worker.1.tariffication.2.minDeltaAmount=10485760
accounting.worker.1.tariffication.2.delay=20
accounting.worker.1.tariffication.2.batchSize=1000
accounting.worker.1.tariffication.3.minDeltaAmount=0
accounting.worker.1.tariffication.3.delay=30
accounting.worker.1.tariffication.3.batchSize=1000
# Трекер (обработка сессий без наработки):
# пауза между заданиями трекинга
accounting.worker.1.tracking.1.delay=20
# максимальное количество проверенных соединений за задание
accounting.worker.1.tracking.1.batchSize=1000
# Трекер (обработка событий):
# пауза между заданиями трекинга (в миллисекундах)
accounting.worker.1.event.tracking.1.delay.millis=200
# максимальное количество проверенных сервисов за задание
accounting.worker.1.event.tracking.1.batchSize=500
# Трекер (обработка сервисов без сессий):
# пауза между заданиями трекинга
accounting.worker.1.serv.tracking.1.delay=60
# максимальное количество проверенных сервисов за задание
accounting.worker.1.serv.tracking.1.batchSize=500
# типы сервисов, которые нужно обрабатывать, через запятую
# (если пусто - будут обрабатываться сервисы всех типов!)
accounting.worker.1.serv.tracking.1.servTypeIds=
# нужно ли активировать учетный период при обработке
# (по умолчанию учетный период активируется при авторизации по RADIUS/DHCP или появлении новой сессии)
accounting.worker.1.serv.tracking.1.accountingPeriodActivate=1
# Количество потоков на worker
accounting.worker.2.thread.count=3
# Сброс в базу трафиков и наработки:
# минимальная наработка, при которой сбрасывать соединения в базу
accounting.worker.2.flushing.1.minDeltaAccount=0
# минимальная сумма трафика, при которой сбрасывать соединение в базу
accounting.worker.2.flushing.1.minDeltaAmount=0
# пауза между заданиями сброса в базу
accounting.worker.2.flushing.1.delay=30
# максимальное количество сброшенных соединений в базу за задание
accounting.worker.2.flushing.1.batchSize=500
# Количество потоков на worker
accounting.worker.3.thread.count=3
# Завершатель соединений:
# пауза между заданиями
accounting.worker.3.finishing.1.delay=20
# максимальное количество сброшенных соединений в базу за задание
accounting.worker.3.finishing.1.batchSize=500
Код:
connection 11-28/11:50:45 ERROR [sa-p-11-t-10] EventWorker - java.util.concurrent.TimeoutException: Timeout waiting for future results will done. Possible answer not recieved.
ru.bitel.bgbilling.common.BGException: java.util.concurrent.TimeoutException: Timeout waiting for future results will done. Possible answer not recieved.
at ru.bitel.bgbilling.kernel.event.AsyncEventWorker.doTasks(AsyncEventWorker.java:115)
at ru.bitel.bgbilling.modules.inet.access.sa.ServiceActivatorDeviceWorker.runWorker(ServiceActivatorDeviceWorker.java:198)
at ru.bitel.bgbilling.kernel.event.EventWorker.internalRunWorker(EventWorker.java:139)
at ru.bitel.bgbilling.modules.inet.access.sa.ServiceActivatorDeviceWorker.runImpl(ServiceActivatorDeviceWorker.java:136)
at ru.bitel.common.worker.WorkerTask.run(WorkerTask.java:86)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
at ru.bitel.common.worker.WorkerThread.run(WorkerThread.java:40)
Caused by: java.util.concurrent.TimeoutException: Timeout waiting for future results will done. Possible answer not recieved.
... 15 more