Member since
07-30-2019
3058
Posts
1526
Kudos Received
889
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
47 | 10-07-2024 06:12 AM | |
226 | 10-02-2024 09:52 AM | |
226 | 10-02-2024 09:39 AM | |
123 | 09-27-2024 10:22 AM | |
233 | 09-27-2024 08:45 AM |
03-06-2017
09:02 PM
1 Kudo
@Eric Lloyd Start troubleshooting your flow by stepping a FlowFile through one processor at a time. Try right clicking on the connections and select "list queue". Clicking the "details" icon to the far left of a FlowFile in the queue list to get details of that FlowFile in that connection.
Does the filename look correct? Thanks, Matt
... View more
03-06-2017
07:10 PM
2 Kudos
@Eric Lloyd Did you try using a "Demarcator" between your merged content? The MergeContent processor allows you to designate a Demarcator. Perhaps use new line or something else unique that can then be used later to differentiate between bits of content in the same HDFS file. Thanks, Matt
... View more
03-06-2017
06:26 PM
@Eric Lloyd If you set an attribute on all your FlowFiles with the a value of "<year/month/day>" for the FlowFile, you can use that attribute as your "Correlation Attribute Name" in the mergeContent processor to make sure that only FlowFile from the same day are added to a bin.
... View more
03-06-2017
06:23 PM
3 Kudos
@Eric Lloyd The MergeContent processor adds FlowFiles from the incoming queue to virtual bins. Once the configured criteria on a bin is met all the FlowFile in that Bin are merged. So if you want to continue to merge incoming FlowFiles until X amount of time has passed then setting the "Max bin age" property is what you want. Note: Be careful how many FlowFiles you merge. The FlowFile attributes for all incoming FlowFiles being merged in a single bin live in the NiFi JVM heap memory. Merging to many FlowFiles at once can result in OutOfMemory (OOM) errors. There is no formula for the exact number you can merge per bundle/bin. It depends on how many attributes exist on a FlowFile and how large the values are associated to those attributes. Thanks, Matt
... View more
03-06-2017
05:10 PM
2 Kudos
@Ayaskant Das NiFi by default will use a user's SSL certificate if it is included by your browser during the connection to NiFi's URL. NiFi can be configured to use LDAP or Kerberos as alternate Authentication methods. Once configured, these alternate methods will be used only if a user does not pass a SSL certificate. Information about setting up LDAP or kerberos can be found in NiFo's Admin guide: https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#user-authentication Thanks, Matt
... View more
03-06-2017
03:30 PM
@Gaurav Jain Please provide full use case and examples. It is difficult to provide assistance without the details. The more the better.
... View more
03-06-2017
03:28 PM
4 Kudos
@Mark Heydenrych While I like the idea, there is currently no way to have a log message written to a FlowFiles attribute upon routing to a failure relationship. You may want to open an Apache NiFi Jira around this idea. Typically the "failure" relationship is routed back on the source processor so that multiple attempts can be made to deliver the file. In cases like network hicups, duplicate files, etc. this makes a lot of sense. When dealing with processor config failures, permissions issues, etc. the file will never be successful. You could set up a failure count loop. This loop would create an attribute on FlowFiles that are routed to "failure" and continue to loop them back on PutHDFS until the count has reached a configured number. Once that count is reached, the FlowFiles could be routed out of the loop. You could then send a notification via putEmail of the failed FlowFile for user investigation. Here is a link to a retry count loop flow NiFi template: https://cwiki.apache.org/confluence/download/attachments/57904847/Retry_Count_Loop.xml?version=1&modificationDate=1433271239000&api=v2 Thanks, Matt
... View more
03-06-2017
03:13 PM
4 Kudos
@adrian white You can use the MergeContent processor followed by a RouteOnAttribute processor to accomplish what you are looking to do. The MergeContent processor writes an attribute named "merge.count" to the FlowFile containing all your merged source flowfiles. - Set Min entries to "50" - Set Max Entries to "50" - Set Max Bin age to "1 min" The bin age timer is trigger once the very first FlowFile is added. At the end of 1 min or 50 FlowFiles (whichever occurs first) the Bin will be merged. Connect the "merged" relationship to a RouteOnAttribute processor that checks the "merge.count" on the merged FlowFiles to verify that they contain 50 entries. "small" will become a new relationship to the RouteOnAttribute processor. - Auto-terminate the "small" relationship so that any merged FlowFile with fewer then 50 entries is deleted. - Route the "unmatched" relationship on down the rest of your dataflow. Thanks, Matt
... View more
03-03-2017
07:51 PM
Is there anything in the nifi-user.log when you try to access the https web address?
I also noticed the URLs are for 10.x.x.x web addresses. Are these address reachable from the system where you have your web browser loaded?
Can you post a screenshot of your browser when you try to access the https web address? Matt
... View more
03-03-2017
07:37 PM
@Ayaskant Das Now we know that your NiFi is up and running. We also know that it has been configured to run securely over https.
After being secured you will not be able to access it over http. Https access will only work if user authentication is successful which comes full circle to my initial response. Here are a few links to assist you there: https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#user-authentication https://community.hortonworks.com/articles/17293/how-to-create-user-generated-keys-for-securing-nif.html
Thanks, Matt
... View more