Member since
07-30-2019
3406
Posts
1622
Kudos Received
1008
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 110 | 12-17-2025 05:55 AM | |
| 171 | 12-15-2025 01:29 PM | |
| 115 | 12-15-2025 06:50 AM | |
| 243 | 12-05-2025 08:25 AM | |
| 405 | 12-03-2025 10:21 AM |
07-17-2018
05:52 PM
1 Kudo
@Andy Liang - The ExecuteSQL processor only supports "Select" statements. - Also see: https://community.hortonworks.com/questions/64667/joining-tables-within-nifi.html - Thank you, Matt - If you found this Answer addressed your original question, please take a moment to login and click "Accept" below the answer.
... View more
07-17-2018
05:42 PM
1 Kudo
For either of these examples you will need to create a "demarcator" file on disk that contains a new line and then point at that file in teh assocaited config in the mergeContent processors to make sure the merged file has one FlowFile content per line.
... View more
07-17-2018
05:36 PM
Here is the flow that could be used base d on just looking at PAN and TIN values in each line: detect-duplicate-attr-in-csv.xml
... View more
07-17-2018
05:17 PM
1 Kudo
@Rinky Arora - Here is a simple flow that will compare lines of a CSV file and delete any that are duplicates: Template of above attached: detect-duplicate-lines-in-csv.xml If you only want to compare the PAN and TIN CSV values only of each line and not the entire line it gets a bit more complicated. You would then need to extract the PAN and TIN Values from the content and use the HashAttribute Processor instead of HashContent. - Hope this help get you going. - Thank you, Matt - If you found this Answer addressed your original question, please take a moment to login and click "Accept" below the answer.
... View more
07-17-2018
02:55 PM
1 Kudo
@federico dell'anese - The particular enhancement you are looking for here was coded in to Apache NIFi 1.7.0 version. Upgrading to this new version of NiFi will allow the FetchFTP processor to create move directories dynamically. The change was covered in the following Apache Jira: https://issues.apache.org/jira/browse/NIFI-5090 - Thank you, Matt - If you found this Answer addressed your original question, please take a moment to login and click "Accept" below the answer.
... View more
07-17-2018
01:42 PM
@SaiKumar Akula The same flow above will still work for you except swap out the GenerateFlowFile processor for a GetFile processor. Simply set a "run schedule" for how often you want the GetFile to read the source file and change "Keep Source File" property to true. Every time the processor executes it will read the source text file and it can be passed to the splitText processor in above flow and so on... As long as you don't change the source file's filename, you can edit whenever you want to add new lines or remove URL lines. - - Thanks, Matt
... View more
07-16-2018
08:11 PM
@Tommy - *** Forum tip: Please try to avoid responding to an Answer by starting a new answer. Instead use the "add comment" tp respond to en existing answer. There is no guaranteed order to different answers which can make following a response thread difficult especially when multiple people are trying to assist you. Also use the @username when replying to make sure user gets notified about your response. - You need to answer the question: What links these two FlowFiles to one another? - Since you are evaluating FlowFiles in pairs. What if you get two Files of type A. How do you want the processor to know what file type B belongs with which of the two type files that already arrived? - If this is not a concern you could use a simple wait/notify flow as described here to accomplish this: https://gist.github.com/ijokarumawak/375915c45071c7cbfddd34d5032c8e90 - Thanks, Matt
... View more
07-16-2018
07:59 PM
@mark juchems The ConsumeAzureEventHub processor was developed in the Apache community. From your description I did not realize it was growing non stop. It sounds like it was written in such away that is gets a thread upon initial execution and never releases that thread. If that is the case it will continue to produce FlowFiles to the output queue regardless of configured back pressure thresholds. - My suggestion would be to open an Apache Jira against that processor explaining the issue it is having and sharing your processor configuration. - Thank you, Matt
... View more
07-16-2018
07:37 PM
3 Kudos
@Mark Lin @mark juchems - The configurable backpressure thresholds (object and size) on a connection are soft limits. So a backpressure object threshold of 10,000 (default) means that the NiFi controller will not schedule the feeding processor to run if the object count has reached or exceeded 10,000 queued FlowFiles. - So lets say there are 9,999 queued objects. NiFi would allow the preceding processor to get scheduled. When that processor executes it code it will execute with no regard for destination queue sizes. That means if the execution of that processor thread results in 1,000,000 FlowFiles being processed in a single execution, all 1,000,000 FlowFiles will be added to that downstream connection queue. Now that the queue has 1,009,999 FlowFiles queued, the preceding processor will not be scheduled again until that queue drops below 10,000 again. - Same soft limit concept applies for the back pressure size threshold setting as well on a connection. - Thank you, Matt - When an "Answer" addresses/solves your question, please select "Accept" beneath that answer. This encourages user participation in this forum.
... View more
07-16-2018
02:49 PM
@Gulshan Agivetova The output of the ListSFTP processor will be a single 0 byte FlowFile for each file that is successfully listed based on the specific processor configuration. So I am not clear on where you get the value for ${list} from? - as far as your script is concerned, I would recommend putting those linux commands in a script on the target ftp server. You can then use ExecuteStreamCommand processor that can call the ssh command to remote in to your ftp server and execute the script containing the linux commands. - Thanks, Matt - If you found this Answer addressed your original question, please take a moment to login and click "Accept" below the answer.
... View more