Member since
06-01-2018
6
Posts
0
Kudos Received
0
Solutions
02-15-2019
03:39 PM
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
Labels:
- Labels:
-
Apache NiFi
06-05-2018
08:29 AM
Matt Clarke, Thank you!
... View more
06-04-2018
04:43 PM
Hi!
Please advise for our case.
We have three separate networks that would perform SNMP integration with devices. The main limitation is that NiFi node in one network can't access to devices in another network. SNMP integration scheme is provided in the picture.
In our view, "Extract IP’s From Provided Ranges" is performing only on the Master node and then through Remote Process Groups would pass IP ranges to nodes in separated networks and then execute an extraction logic. Is there a way to send the task to particular node group?
Thank you!
... View more
Labels:
- Labels:
-
Apache NiFi