[jira] [Resolved] (NIFI-6744) PutSolrContentStream Processor does not route to connection_failure in Cloud mode if Zookeeper is not running

["Pierre Villard (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/NIFI-6744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Pierre Villard resolved NIFI-6744.
----------------------------------
    Resolution: Feedback Received

Apache NiFi 1.x is no longer maintained and no new release is planned on the 1.x release line. Marking as resolved as part of a cleanup operation. Please open a new one with an updated description if this is still relevant for NiFi 2.x.

> PutSolrContentStream Processor does not route to connection_failure in Cloud mode if Zookeeper is not running
> -------------------------------------------------------------------------------------------------------------
>
>                 Key: NIFI-6744
>                 URL: https://issues.apache.org/jira/browse/NIFI-6744
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Core Framework
>    Affects Versions: 1.9.2
>            Reporter: Yuriy Flyud
>            Priority: Major
>
> Solr processors would not detect connection failure in case ZK is not running. When this happens a SolrException is thrown. The following causes should route a flow file to a connection_failure:
>  * java.util.concurren.TimeoutException - when ZK was down during Solr processor start
>  * org.apache.zookeeper.KeeperException.ConnectionLossException - when ZK stopped after Solr processor was started and connection established.
> This could be fixed by implementing a SolrException handling in the following way:
> {code:java}
> catch (SolrException e) {
>   //Additional handling of ZK connection exceptions.
>   if (causedByException(e, TimeoutException.class) || causedByException(e, ConnectionLossException.class)) {
>     connectionError.set(e);
>   } else {
>     error.set(e);
>   }
> ...
> private boolean causedByException(Exception e, Class<? extends Exception> ec) {
>   boolean foundException = false;
>   Throwable cause = e.getCause();
>   while (cause != null) {
>     if (ec.isInstance(cause)) {
>       foundException = true;
>       break;
>     }
>     cause = cause.getCause();
>   }
>   return foundException;
> }{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)