You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Joel (Jira)" <ji...@apache.org> on 2026/04/01 21:38:00 UTC
[jira] [Updated] (NIFI-15782) Reconnect to mail server on failure
[ https://issues.apache.org/jira/browse/NIFI-15782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Joel updated NIFI-15782:
------------------------
Affects Version/s: (was: 2.7.2)
> Reconnect to mail server on failure
> -----------------------------------
>
> Key: NIFI-15782
> URL: https://issues.apache.org/jira/browse/NIFI-15782
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 2.4.0
> Reporter: Joel
> Priority: Minor
> Labels: email
>
> The ConsumeIMAP (and most likely ConsumePOP3) processors enter a permanent failed state when the connection to the email server is interrupted (e.g., network issues, server restarts, timeouts). These processors do not automatically recover from this state, requiring a full NiFi restart to resume email consumption.
> Bellow is one example of when the ConsumeIMAP enters the failed state:
> {{org.apache.nifi.processor.exception.ProcessException: Failed to receive messages from Email server: [jakarta.mail.StoreClosedException - * BYE Jakarta Mail Exception: java.io.IOException: Connection dropped by server?}}
> {{ at org.apache.nifi.processors.email.AbstractEmailProcessor.fillMessageQueueIfNecessary(AbstractEmailProcessor.java:374)}}
> {{ at org.apache.nifi.processors.email.AbstractEmailProcessor.receiveMessage(AbstractEmailProcessor.java:426)}}
> {{ at org.apache.nifi.processors.email.AbstractEmailProcessor.onTrigger(AbstractEmailProcessor.java:235)}}
> {{ at org.apache.nifi.processors.email.ConsumeIMAP.onTrigger(ConsumeIMAP.java:31)}}
> {{ at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)}}
> {{ at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1272)}}
> {{ at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:244)}}
> {{ 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: jakarta.mail.StoreClosedException: * BYE Jakarta Mail Exception: java.io.IOException: Connection dropped by server?}}
> {{ at org.eclipse.angus.mail.imap.IMAPFolder.throwClosedException(IMAPFolder.java:3740)}}
> {{ at org.eclipse.angus.mail.imap.IMAPFolder.doCommand(IMAPFolder.java:3874)}}
> {{ at org.eclipse.angus.mail.imap.IMAPFolder.exists(IMAPFolder.java:600)}}
> {{ at org.springframework.integration.mail.AbstractMailReceiver.openFolder(AbstractMailReceiver.java:361)}}
> {{ at org.springframework.integration.mail.AbstractMailReceiver.receive(AbstractMailReceiver.java:387)}}
> {{ at org.apache.nifi.processors.email.AbstractEmailProcessor.fillMessageQueueIfNecessary(AbstractEmailProcessor.java:369)}}
> {{ ... 14 common frames omitted}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)