Deque Full Exception - Доска объявлений - PullRequest
Новая
       91

Deque Full Exception - Доска объявлений

1 голос
/ 04 августа 2020

У меня проблемы с использованием платформы Thingsboard (IoT) при имитации 7,5К устройств, отправляющих данные на платформу. У меня в журналах появляется следующая ошибка, как только я начинаю отправлять данные (через MQTT): 

2020-08-01 01:17:06,946 [ForkJoinPool-12-worker-0] ERROR c.g.c.u.concurrent.AggregateFuture - Got more than one input Future failure. Logging failures after the first
java.lang.IllegalStateException: Deque full
    at java.util.concurrent.LinkedBlockingDeque.addLast(LinkedBlockingDeque.java:335)
    at java.util.concurrent.LinkedBlockingDeque.add(LinkedBlockingDeque.java:633)
    at org.thingsboard.server.dao.util.AbstractBufferedRateExecutor.submit(AbstractBufferedRateExecutor.java:109)
    at org.thingsboard.server.dao.nosql.CassandraAbstractDao.executeAsync(CassandraAbstractDao.java:93)
    at org.thingsboard.server.dao.nosql.CassandraAbstractDao.executeAsyncWrite(CassandraAbstractDao.java:76)
    at org.thingsboard.server.dao.timeseries.CassandraBaseTimeseriesDao.savePartition(CassandraBaseTimeseriesDao.java:434)
    at org.thingsboard.server.dao.timeseries.BaseTimeseriesService.saveAndRegisterFutures(BaseTimeseriesService.java:153)
    at org.thingsboard.server.dao.timeseries.BaseTimeseriesService.save(BaseTimeseriesService.java:144)
    at org.thingsboard.server.service.telemetry.DefaultTelemetrySubscriptionService.saveAndNotify(DefaultTelemetrySubscriptionService.java:124)
    at org.thingsboard.rule.engine.telemetry.TbMsgTimeseriesNode.onMsg(TbMsgTimeseriesNode.java:89)
    at org.thingsboard.server.actors.ruleChain.RuleNodeActorMessageProcessor.onRuleChainToRuleNodeMsg(RuleNodeActorMessageProcessor.java:107)
    at org.thingsboard.server.actors.ruleChain.RuleNodeActor.onRuleChainToRuleNodeMsg(RuleNodeActor.java:97)
    at org.thingsboard.server.actors.ruleChain.RuleNodeActor.doProcess(RuleNodeActor.java:60)
    at org.thingsboard.server.actors.service.ContextAwareActor.process(ContextAwareActor.java:45)
    at org.thingsboard.server.actors.TbActorMailbox.processMailbox(TbActorMailbox.java:121)
    at java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1402)
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)

Я попытался найти в Google причину, но я ничего не нашел.

При моделировании с помощью устройств 5K эта ошибка возникала 3 раза в день (в течение 4-дневного периода), но в конечном итоге она перестала показывать эту ошибку. Однако при увеличении количества устройств ошибка постоянна. Я использую Kafka в качестве брокера, но я не вижу ошибок, связанных с Kafka. Я просто хочу знать, почему появляется ошибка, связано ли это с памятью или каким-либо другим ограничением?

Заранее спасибо

Francisco P

...