Member since
07-30-2019
3472
Posts
1642
Kudos Received
1020
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 278 | 06-03-2026 06:06 PM | |
| 547 | 05-06-2026 09:16 AM | |
| 1095 | 05-04-2026 05:20 AM | |
| 617 | 05-01-2026 10:15 AM | |
| 723 | 03-23-2026 05:44 AM |
01-17-2024
06:58 AM
@Sartha Your MiNiFi needs a simple dataflow that consists of a TailFile processor and then either a Remote Process Group (RPG) (recommended if your NiFi is a multi-node cluster, but can be used with single instance NiFi as well.) or a PostHTTP processor (Use if NiFi a single instance and not a cluster). Neither the RPG not the PostHTTP can be configured with a target URL with "localhost". Localhost would be the MiNiFi server. It needs to be the hostname of the server where your NiFi is running. Make sure if using RPG, you have configured the Site-to-Site properties in the nifi.properties file. Your NiFi would need a Remote Input Port (this is what your MiNiFi RPG will transmit FlowFiles to) or a ListenHTTP processor (if you used PostHTTP on your MiNiFi, this is what it can be configured to send to). The outbound connection from either of these components needs to feed whatever downstream processors you need to do within NiFi. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-17-2024
06:37 AM
1 Kudo
@glad1 No not necessary. I suggested becasue i was still unclear how often your initial ExecuteSQL was producing a source file. The PG makes it easy to throttle per source FLowFile processing so you would get one merged FlowFile for each produced FlowFile. Thanks, Matt
... View more
01-12-2024
07:00 AM
@manishg I am not clear on what you are trying to accomplish here. What is the use case? What is your NiFi version? What is your OS? NiFi does not have a "start.sh" script. Are you talking about the "nifi.sh" script. Perhaps there are just some important details I am missing here. also not sure why you would want to change the nifi..web.http.port configuration property in the nifi.properties file to a variable. These properties are all read during startup of NiFi and evaluating NiFi variables is does not happen during NiFi startup. Nor does NiFi support defining NiFi variables in the nifi.properties file. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-12-2024
06:46 AM
@pratschavan You may find the guidance provided below useful: https://stackoverflow.com/questions/47200178/read-message-body-of-an-email-using-apache-nifi Instead of using consumePOP3 processor to get your msg files directly from an email server, you would simply ingest those files from your msg storage folder(s). As far as interacting with your SQL DB, there are numerous documented SQL processor: https://nifi.apache.org/docs/nifi-docs/ If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-12-2024
06:09 AM
1 Kudo
@Madhav_VD What about the "Relationship" tab? My guess here is that you have checked the "retry" box on the success relationship of the putSQL processor. If that is the case, unchecking "retry" on the success relationship should resolve your FlowFile penalization issue: When this processor is running, does it produce any bulletins or exceptions in the log output? If it is producing bulletins, warn, or error logs, it is likely failing to write to your SQL DB. The FlowFIle would then be routed to retry or failure relationship depending on exception where "retry" if checked would be applied based on retry property configurations. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-12-2024
06:07 AM
@LKB I recommend creating a new community question with the details around yoru setup and exceptions you may be seeing. You are more likely to get better traction on a community question that does not already have and accepted solution. Thank you, Matt
... View more
01-11-2024
02:09 PM
@Madhav_VD How has yoru PutSQL processor been configured (all tabs)? For a FlowFile(s) to be penalized a processor needs to apply that penalty. That could be applied by the PutSQL if you configure retry on a relationship or being applied by the processor feeding the connection. Looking at your attached dataflow, I don't believe the EvaluateJsonPath processor is applying any such penalty. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-11-2024
02:03 PM
@joyjlee The File-User-Group-Provider is responsible for: 1. Creating the users.xml using the configured provider properties ONLY if the users.xml file does not already exist. 2. Loading the users from the users.xml in to heap memory on startup when the users.xml already exists. The File-Access-Policy-Provider is responsible for: 1. Generating the authorizations.xml file ONLY if it does not already exist using the configured provider properties. This provider will not work if users are not already loaded by some user group provider (multiple options exist for loading users: file-user-group-provider, ldap-user-group-provider, shell-user-group-provider, etc.) 2. Loading the user's authorizations into memory if the authorizations.xml file already exists. So by creating your own custom users.xml and authorizations.xml files, these providers do nothing beyond loading what is already in those files into memory. They will not append to or modify them. NiFI does not support wildcard policies either. The UUID generated by NiFi for a User Identity string will always be the same. So I am assuming you captured all those UUID for the users.xml you are manually creating. Also NiFi only generates the flow.json.gz (replacing flow.xml.gz) if it does not already exist. While upon creation initially the UUID for the root process group will be random, you could certainly load a pre-built flow.json.gz with your deployment that only has that root PG already in it. That would allow your pre-built users.xml and authorizations.xml to load with policies you defined. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-11-2024
01:41 PM
1 Kudo
@enam Looks like you have a bad file filter regex in your listSFTP processor configuration. .*file.*\.xls Above looks for any character for 1 or more characters until is finds the last occurrence of string "file" followed by any character for as many characters until last occurrence of string ".xls". However, all your filenames start with "file" and have no characters before it. Try modifying your file filter regex by removing the ".*" before "file": file.*\.xls Right click on processor, select "view state", and then "clear state". Then start the listSFTP processor again to see if generated NiFi FlowFiles for each file on your SFTP server. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-11-2024
01:28 PM
1 Kudo
@Anderosn Is your InvokeHTTP processor triggered by a FlowFile from an inbound connection to the processor or does it have no inbound connections and executes purely based on configured run schedule? This is one of very few processors where an inbound connection is optional, but behavior is different dependent on the configuration chosen. With no inbound connection there is no FlowFile to "retry" when you encounter "failure" or "No retry" result from execution. Because really it is retrying every time it executes essentially with no inbound connection. You could use a GenerateFlowFile processor to feed an empty trigger FlowFile to the invokeHTTP processor to trigger its execution. This would then give you a FlowFile that Retry configuration can use. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more