Member since
12-03-2017
140
Posts
20
Kudos Received
11
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
605 | 11-03-2023 12:17 AM | |
2114 | 12-12-2022 09:16 PM | |
758 | 07-14-2022 03:25 AM | |
1271 | 07-28-2021 04:42 AM | |
1598 | 06-23-2020 10:08 PM |
06-15-2020
12:48 PM
@stevenmatison I still haven't had any luck with this at all. Do you know if an error on one specific file could cause the entire process to crash and not complete or does it attempt to skip over bad files?
... View more
06-09-2020
01:55 AM
Great, thanks a lot
... View more
06-05-2020
08:23 AM
@vikrant_kumar24 - Have you found a better way to solve this ? If so would be curious to hear that!
... View more
09-03-2019
01:28 PM
hi @nshawa, I am having the following error on PutHiveStreaming processor after running the template you provided: Any idea how to fix this?
... View more
04-04-2019
01:16 PM
1 Kudo
@Mahendra Hegde, I've built the flow as described. It works as expected without any exception. I just have formatted the value of condition for RouteOnAttribute. I've tested on latest build (1.10.0-SNAPSHOT). Please verify your version. Please let us know version number and share the exception (logs).
... View more
12-05-2018
11:34 AM
Thank you, its working with ${anyDelineatedValue("${your_attribute}", ","):equals("US")}
... View more
11-23-2018
05:54 AM
Thanks @Shu ! It worked, I was using 'Return type' as auto instead of json in EvaluateJsonPath. Thanks for the reply 🙂
... View more
11-20-2018
08:43 AM
2 Kudos
@Mahendra Hegde it's possible in NiFi but it depends on how frequently you are going to restart NiFi instance. Use GenerateFlowFile (or) other processors and schedule the processor as shown below With the above schedule GenerateFlowFile processor going to run once we start processor and next run will be after 1111111110 sec (or) when you restart NiFi instance. For your case adjust the Run Schedule time based on your NiFi restart time.
... View more
10-30-2018
03:42 PM
Thanks @Matt Burgess for clear information. Do you suggest any other approach? I am open for any kind of storage or caching, but end goal is I should be able to use some master data for every flow file validation without impacting performance..... (Master data is combination of company-country-datatype : this i want to use for every flow file validation) Thanks for your response 🙂 Mahendra
... View more
07-24-2018
02:29 AM
@Mahendra Hegde
You can use EvaluateJsonPath processor to extract the value from $.tripSummaryMetaData.orgId then keep as attribute to the flowfile then use RouteOnAttribute processor to check the value of the attribute, 1.If empty then feed to doesn't feed the json message to Jolt transform processor. 2.if not empty then feed the relationship to add the default operation. (or) Use Update Record processor and configure Record Reader/Writer controller services(in writer keep supress null values to true) then using RecordPathvalue, check the value exists for the specific record path by using record path guide, then use If else function to add default value. References regarding UpdateRecord and Record Path Guide
... View more
- « Previous
- Next »