We have NiFi cluster in the Openshift environment. There is a problem with restarts of a non-persistent NiFi: cluster identifies restarted node as a new one. What a file must be stored at the persistent volumes? ... View more

Hello. How can we export/import controller services separately from the processors? ... View more

Hello! TC to reproduce: 1) Create GenerateFlowFile with the next Custom Text: select 1 from dual union all select 2 from dual union all select 3 from dual 2) Create ExecuteSQL. Set "Output Batch Size" = 1. 3) Start AR: nifi-bug.png ER: 3 flowfiles in the "success" connection. Root Cause: if (outputBatchSize > 0 && resultSetFlowFiles.size() >= outputBatchSize) { session.transfer(resultSetFlowFiles, REL_SUCCESS); session.commit(); resultSetFlowFiles.clear(); } Commit method has the next requirement: Commits the current session ensuring all operations against FlowFiles within this session are atomically persisted. All FlowFiles operated on within this session must be accounted for by transfer or removal or the commit will fail. At the time of any commit, an input FlowFile (fileToProcess) still exists and has not been accounted for by transfer or removal. How can it be worked around? We have the same issue with the custom processor. ... View more

Hello everyone! We have a very strange situation in our NiFi flow. The problem is that the result was with an unexpectable content from flow files that existing in the distinct flow. The flow above generates in the first GenerateFlowFile processor the next content: <extract> <SNMPSCANNER> <line> <ip>127.0.0.1</ip> <port>10001</port> <protocol>udp</protocol> <address>udp:127.0.0.1/10001</address> <community>airos</community> <status>0</status> <sysName>sysName</sysName> </line> </SNMPSCANNER> </extract> and it falls into the result of the below flow after our custom SnmpProcessor. How can it be? The above flow was turned off during the execution of below. ... View more