markap14 commented on PR #5945:
URL: https://github.com/apache/nifi/pull/5945#issuecomment-1095069965
I tested this by forcing a processor to generate an error. I used
GenerateFlowFile to generate a FlowFile with the content "hello" and then sent
to CompressContent. Configured CompressContent to decompress gzip. This should
fail since the content is not gzipped, it's just the text "hello". But the
error message written to the logs was:
```
2022-04-11 09:39:24,963 ERROR [Timer-Driven Process Thread-5]
o.a.n.p.standard.CompressContent
[CompressContent[id=33f515be-1000-1180-fa23-4e3424088fe0], decompress,
StandardFlowFileRecord[uuid=770a869d-a200-4eb4-bd6d-093a75ad3fb8,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1649684358971-1, container=default,
section=1], offset=0,
length=58],offset=0,name=770a869d-a200-4eb4-bd6d-093a75ad3fb8,size=58], gzip]
Unable to {} {} using {} compression format due to {}; routing to failure
org.apache.nifi.processor.exception.ProcessException: IOException thrown
from CompressContent[id=33f515be-1000-1180-fa23-4e3424088fe0]:
java.io.IOException: java.io.IOException: Input is not in the .gz format
at
org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:3437)
at
org.apache.nifi.processors.standard.CompressContent.onTrigger(CompressContent.java:282)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1283)
at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:214)
at
org.apache.nifi.controller.scheduling.AbstractTimeBasedSchedulingAgent.lambda$doScheduleOnce$0(AbstractTimeBasedSchedulingAgent.java:63)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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)
Caused by: java.io.IOException: java.io.IOException: Input is not in the .gz
format
at
org.apache.nifi.processors.standard.CompressContent$1.process(CompressContent.java:373)
at
org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:3416)
... 13 common frames omitted
Caused by: java.io.IOException: Input is not in the .gz format
at
org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream.init(GzipCompressorInputStream.java:193)
at
org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream.<init>(GzipCompressorInputStream.java:167)
at
org.apache.nifi.processors.standard.CompressContent$1.process(CompressContent.java:351)
... 14 common frames omitted
```
So some variables didn't get substituted in:
```
Unable to {} {} using {} compression format due to {}; routing to failure
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
