Hi

In ExtractEmailAttachments possible exception

```
org.apache.nifi.processor.exception.ProcessException: IOException thrown
from ExtractEmailAttachments[id=116ac3ca-3f4e-346f-af3e-8de2bd685650]:
org.eclipse.angus.mail.util.DecodingException: BASE64Decoder: Error in
encoded stream: needed 4 valid base64 characters but only got 3 before EOF,
the 10 most recent characters were: "t-ldr1--\r\n"
        at
org.apache.nifi.controller.repository.StandardProcessSession.append(StandardProcessSession.java:3246)
        at
org.apache.nifi.processors.email.ExtractEmailAttachments.lambda$onTrigger$1(ExtractEmailAttachments.java:138)
        at
org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2672)
        at
org.apache.nifi.processors.email.ExtractEmailAttachments.onTrigger(ExtractEmailAttachments.java:104)
        at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
        at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1276)
        at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:220)
        at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:102)
        at
org.apache.nifi.engine.FlowEngine.lambda$wrap$1(FlowEngine.java:105)
        at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
        at
java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358)
        at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
        at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
        at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
        at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: org.eclipse.angus.mail.util.DecodingException: BASE64Decoder:
Error in encoded stream: needed 4 valid base64 characters but only got 3
before EOF, the 10 most recent characters were: "t-ldr1--\r\n"
        at
org.eclipse.angus.mail.util.BASE64DecoderStream.decode(BASE64DecoderStream.java:247)
        at
org.eclipse.angus.mail.util.BASE64DecoderStream.read(BASE64DecoderStream.java:128)
        at
java.base/java.io.FilterInputStream.read(FilterInputStream.java:95)
        at org.apache.nifi.stream.io.StreamUtils.copy(StreamUtils.java:35)
        at
org.apache.nifi.processors.email.ExtractEmailAttachments.lambda$onTrigger$0(ExtractEmailAttachments.java:138)
        at
org.apache.nifi.controller.repository.StandardProcessSession.append(StandardProcessSession.java:3196)
        ... 14 common frames omitted

```



```
Index:
nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailAttachments.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git
a/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailAttachments.java
b/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailAttachments.java
---
a/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailAttachments.java
(revision a7e336f416a0f31af354451b70e2cce6696ff71d)
+++
b/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailAttachments.java
(date 1754994166499)
@@ -135,9 +135,9 @@
                         String parentUuid =
originalFlowFile.getAttribute(CoreAttributes.UUID.key());
                         attributes.put(ATTACHMENT_ORIGINAL_UUID,
parentUuid);
                         attributes.put(ATTACHMENT_ORIGINAL_FILENAME,
originalFlowFileName);
-                        split = session.append(split, out ->
StreamUtils.copy(data.getInputStream(), out));
-                        split = session.putAllAttributes(split,
attributes);
                         attachmentsList.add(split);
+                        split = session.append(split, out ->
StreamUtils.copy(data.getInputStream(), out));
+                        session.putAllAttributes(split, attributes);
                     }
                 } catch (FlowFileHandlingException e) {
                     // Something went wrong

```


-- 
Павел

Reply via email to