[
https://issues.apache.org/jira/browse/CAMEL-21769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929094#comment-17929094
]
Narsi Reddy Nallamilli commented on CAMEL-21769:
------------------------------------------------
Nope the jvm doesn't crashes and the app continues to run in this instance.
It's just that thread which gets sacrificed. Since the app continues normally
and that specific exchange gets trapped it continues to extend the visibility .
I am sure I have tested it the app runs fine despite the error.
> camel-aws-sqs - Error is causing the sqs message to be extended forever
> -----------------------------------------------------------------------
>
> Key: CAMEL-21769
> URL: https://issues.apache.org/jira/browse/CAMEL-21769
> Project: Camel
> Issue Type: Bug
> Components: camel-aws2-sqs
> Affects Versions: 4.8.0
> Reporter: Narsi Reddy Nallamilli
> Assignee: Claus Ibsen
> Priority: Minor
> Fix For: 4.8.4, 4.10.1, 4.11.0
>
>
> Below scenario the processing of the message threw memory error. so further
> processing of the exchange aborted, however the exchange couldn't get
> released from Sqs2Consumer timeoutExtender, as a result the message gets
> visibility extended forever causing the entire aws sqs queue to get blocked.
> {code:java}
> 2025-02-18T00:01:20.793Z [C#964 T#45 - aws2-sqs://prod_sync_events.fifo -
> JE_ID 45901665] #033[36mo.a.c.s.ScheduledPollConsumer#033[m
> #033[1;31mERROR#033[m - Error occurred during running scheduled task on:
> aws2-sqs://prod_sync_events.fifo?amazonSQSClient=%23sqsClient&configuration=%23syncEventsSQSConfiguration,
> due: Java heap space. This exception is ignored and the task will run again
> on next poll.
> java.lang.OutOfMemoryError: Java heap space
> #011at java.base/java.util.Arrays.copyOf(Arrays.java:3537) ~[?:?]
> #011at
> java.base/java.io.ByteArrayOutputStream.ensureCapacity(ByteArrayOutputStream.java:100)
> ~[?:?]
> #011at
> java.base/java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:130)
> ~[?:?]
> #011at
> org.apache.camel.converter.stream.CachedOutputStream.write(CachedOutputStream.java:108)
> ~[camel-support-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.support.builder.OutputStreamBuilder.write(OutputStreamBuilder.java:58)
> ~[camel-support-4.8.0.jar:4.8.0]
> #011at java.base/java.io.InputStream.transferTo(InputStream.java:783) ~[?:?]
> #011at org.apache.camel.util.IOHelper.copy(IOHelper.java:165)
> ~[camel-util-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.component.http.HttpProducer.doExtractResponseBodyAsStream(HttpProducer.java:592)
> ~[camel-http-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.component.http.HttpProducer.extractResponseBody(HttpProducer.java:579)
> ~[camel-http-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.component.http.HttpProducer.populateResponse(HttpProducer.java:351)
> ~[camel-http-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.component.http.HttpProducer.lambda$process$1(HttpProducer.java:272)
> ~[camel-http-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.component.http.HttpProducer$$Lambda$2092/0x00007f8880e1bc78.handleResponse(Unknown
> Source) ~[?:?]
> #011at
> org.apache.camel.component.http.HttpProducer.executeMethod(HttpProducer.java:486)
> ~[camel-http-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.component.http.HttpProducer.process(HttpProducer.java:247)
> ~[camel-http-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:65)
> ~[camel-support-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.processNonTransacted(SharedCamelInternalProcessor.java:156)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:133)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:89)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:82)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:86)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:178)
> ~[camel-support-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:137)
> ~[camel-base-engine-4.8.0.jar:4.8.0]
> #011at com.ac.system.service.ACMHTTPService.execute(ACMHTTPService.kt:49)
> ~[classes/:?]
> #011at
> com.ac.system.core.ACMServiceManager.getEntityList(ACMServiceManager.kt:46)
> ~[classes/:?]
> #011at
> com.ac.system.job.ACMProjectJob.processUpdatedProjectEvent(ACMProjectJob.kt:51)
> ~[classes/:?]
> #011at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method) ~[?:?]
> #011at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
> ~[?:?]
> #011at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:?]
> #011at java.base/java.lang.reflect.Method.invoke(Method.java:569) ~[?:?]
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
