You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by FabryProg <fa...@gmail.com> on 2018/12/18 14:43:47 UTC

SynchronizedExchange: Exception occurred during onCompletion

Hello

Occasionally, we have a WARNING into our camel project.

We are using disruptor queue implementation

what should it be? Is it an error or warning message? is it dangerous?

we cannot reproduce it programmatically!

Thanks

2018-12-16 19:13:44,638 WARN
[org.apache.camel.component.disruptor.SynchronizedExchange] - <Exception
occurred during onCompletion. This exception will be ignored.> ()
java.util.ConcurrentModificationException
    at java.util.HashMap$HashIterator.nextNode(HashMap.java:1442)
    at java.util.HashMap$EntryIterator.next(HashMap.java:1476)
    at java.util.HashMap$EntryIterator.next(HashMap.java:1474)
    at java.util.HashMap.putMapEntries(HashMap.java:512)
    at java.util.HashMap.putAll(HashMap.java:785)
    at
org.apache.camel.util.ExchangeHelper.copyResults(ExchangeHelper.java:379)
    at
org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:33)
    at
org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
    at
org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
    at
org.apache.camel.component.disruptor.AbstractSynchronizedExchange.performSynchronization(AbstractSynchronizedExchange.java:55)
    at
org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:35)
    at
org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
    at
org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
    at
org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:243)
    at
org.apache.camel.util.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:65)
    at
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:685)
    at
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:634)
    at
org.apache.camel.processor.CamelInternalProcessor$InternalCallback.done(CamelInternalProcessor.java:251)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:127)
    at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
    at
org.apache.camel.component.disruptor.DisruptorConsumer.process(DisruptorConsumer.java:175)
    at
org.apache.camel.component.disruptor.DisruptorConsumer.access$000(DisruptorConsumer.java:42)
    at
org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:213)
    at
org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:193)
    at
com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:129)
    at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

Re: SynchronizedExchange: Exception occurred during onCompletion

Posted by Fabrizio Favitta <fa...@bizmate.it>.
Hi,
I'm a fabryprog colleague, our version is v2.20.4 we tried only on this version because we cannot reproduce this warning in our internal tests.

Thanks a lot,
Fabrizio

________________________________
Da: Claus Ibsen <cl...@gmail.com>
Inviato: martedì 18 dicembre 2018 15:56
A: users@camel.apache.org
Oggetto: Re: SynchronizedExchange: Exception occurred during onCompletion

What version of Camel do you use? And have you tried with a newer version

On Tue, Dec 18, 2018 at 3:44 PM FabryProg <fa...@gmail.com> wrote:
>
> Hello
>
> Occasionally, we have a WARNING into our camel project.
>
> We are using disruptor queue implementation
>
> what should it be? Is it an error or warning message? is it dangerous?
>
> we cannot reproduce it programmatically!
>
> Thanks
>
> 2018-12-16 19:13:44,638 WARN
> [org.apache.camel.component.disruptor.SynchronizedExchange] - <Exception
> occurred during onCompletion. This exception will be ignored.> ()
> java.util.ConcurrentModificationException
>     at java.util.HashMap$HashIterator.nextNode(HashMap.java:1442)
>     at java.util.HashMap$EntryIterator.next(HashMap.java:1476)
>     at java.util.HashMap$EntryIterator.next(HashMap.java:1474)
>     at java.util.HashMap.putMapEntries(HashMap.java:512)
>     at java.util.HashMap.putAll(HashMap.java:785)
>     at
> org.apache.camel.util.ExchangeHelper.copyResults(ExchangeHelper.java:379)
>     at
> org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:33)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
>     at
> org.apache.camel.component.disruptor.AbstractSynchronizedExchange.performSynchronization(AbstractSynchronizedExchange.java:55)
>     at
> org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:35)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
>     at
> org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:243)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:65)
>     at
> org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:685)
>     at
> org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:634)
>     at
> org.apache.camel.processor.CamelInternalProcessor$InternalCallback.done(CamelInternalProcessor.java:251)
>     at org.apache.camel.processor.Pipeline.process(Pipeline.java:127)
>     at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer.process(DisruptorConsumer.java:175)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer.access$000(DisruptorConsumer.java:42)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:213)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:193)
>     at
> com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:129)
>     at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
>     at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
>     at java.lang.Thread.run(Thread.java:748)



--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2

Re: SynchronizedExchange: Exception occurred during onCompletion

Posted by Claus Ibsen <cl...@gmail.com>.
What version of Camel do you use? And have you tried with a newer version

On Tue, Dec 18, 2018 at 3:44 PM FabryProg <fa...@gmail.com> wrote:
>
> Hello
>
> Occasionally, we have a WARNING into our camel project.
>
> We are using disruptor queue implementation
>
> what should it be? Is it an error or warning message? is it dangerous?
>
> we cannot reproduce it programmatically!
>
> Thanks
>
> 2018-12-16 19:13:44,638 WARN
> [org.apache.camel.component.disruptor.SynchronizedExchange] - <Exception
> occurred during onCompletion. This exception will be ignored.> ()
> java.util.ConcurrentModificationException
>     at java.util.HashMap$HashIterator.nextNode(HashMap.java:1442)
>     at java.util.HashMap$EntryIterator.next(HashMap.java:1476)
>     at java.util.HashMap$EntryIterator.next(HashMap.java:1474)
>     at java.util.HashMap.putMapEntries(HashMap.java:512)
>     at java.util.HashMap.putAll(HashMap.java:785)
>     at
> org.apache.camel.util.ExchangeHelper.copyResults(ExchangeHelper.java:379)
>     at
> org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:33)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
>     at
> org.apache.camel.component.disruptor.AbstractSynchronizedExchange.performSynchronization(AbstractSynchronizedExchange.java:55)
>     at
> org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:35)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
>     at
> org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:243)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:65)
>     at
> org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:685)
>     at
> org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:634)
>     at
> org.apache.camel.processor.CamelInternalProcessor$InternalCallback.done(CamelInternalProcessor.java:251)
>     at org.apache.camel.processor.Pipeline.process(Pipeline.java:127)
>     at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer.process(DisruptorConsumer.java:175)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer.access$000(DisruptorConsumer.java:42)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:213)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:193)
>     at
> com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:129)
>     at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
>     at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
>     at java.lang.Thread.run(Thread.java:748)



-- 
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2