Member since
07-30-2019
3396
Posts
1619
Kudos Received
1001
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 422 | 11-05-2025 11:01 AM | |
| 327 | 11-05-2025 08:01 AM | |
| 462 | 11-04-2025 10:16 AM | |
| 678 | 10-20-2025 06:29 AM | |
| 818 | 10-10-2025 08:03 AM |
11-14-2016
08:04 PM
1 Kudo
@Saikrishna Tarapareddy Sounds like your Conditional EL statements are not resulting in a boolean true in your UpdateAttribute processor.
After some FlowFiles get routed through the UpdateAttribute let them queue on the outbound connection (Stop the next processor). Right click on the connection and select "List queue". Click on the "view details" icon to the far left of a FlowFile and look at the Attributes on that FlowFile. Do you see the expected "Folder" attribute? is it set to the correct value? If it does not exist, does the filename match exactly one of the provided strings in your EL condition statements? Thanks, Matt
... View more
11-14-2016
01:09 PM
1 Kudo
@Lucas Alvarez The SplitJSON processor splits an incoming JSON on to multiple output JSON messages. You should use the EvaluateJSONPath processor to extract the URL from your splits and ssign them to a FlowFIle attribute you acn then use in your InvokeHTTP processor. Thanks, Matt
... View more
11-11-2016
05:06 PM
1 Kudo
@Raj B The toDate NiFi expression Language function expected the input to this function to define the current format of the value it is being passed. The result is the number of milliseconds since Jan. 1st 1970. The Format function will take a standard date of format number milliseconds since Jan 1st 1970 and convert it into the desired output format as defined in teh function. Assuming you have an attribute Abc.DateTimeOfMessage with a value of 20161011075959, teh following NiFi EL statement will produce the output '2016/10/11 07:59:59': ${Abc.DateTimeOfMessage:toDate('yyyyMMddHHmmss'):format('yyyy/MM/dd HH:mm:ss')} The above EL statement firs convert the dat you have into the standard date format (milliseconds since 1/1/1970) using the toDate function and then pass that result to the format function which converts a standard dat format into the desired output string you are looking for. *** An alternative EL that will yield the sam result is: ${Abc.DateTimeOfMessage:replaceAll('^([0-9]{4})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})','$1/$2/$3 $4:$5:$6')} The above uses the EL replaceAll function uses java capture groups to break apart the incoming function and then uses the values of those 6 capture groups to reconstruct the output in the format you want. There are even more ways, but I figured this is good enough. Thanks, Matt
... View more
11-10-2016
01:21 PM
@vlundberg This has nothing to do with being installed via Ambari. If the core-site.xml file that is being used by the HDFS processor in NiFi reference a Class which NiFi does not include, you will get a NoClassDef found error. Adding new Class to NiFi's HDFS NAR bundle may be a possibility, but as I am not a developer i can't speak to that. You can always file an Apache Jira against NiFi for this change. https://issues.apache.org/jira/secure/Dashboard.jspa Thanks, Matt
... View more
11-10-2016
01:01 PM
4 Kudos
@kumar Check out this template as it will do exactly what you are looking for: Retry_Count_Loop.xml Just feed your failure relationship in to this process group and the output from this process group back to your processor. Thanks, Matt
... View more
11-09-2016
04:40 PM
1 Kudo
@Obaid Salikeen Unfortunately the answer is no at this time. NiFi has zookeeper as a dependency in HDF Ambari, so it is installed when the NiFi service is selected. Once NiFi is deployed there is nothing stopping you from updating the NiFi configs via Ambari to point at your existing Zookeeper you already have installed elsewhere. Keep in mind that other service within the HDF Ambari stack also rely on Zookeeper, so you may need to reconfigure them as well. Matt
... View more
11-09-2016
03:53 PM
@Vinod Chhabria We should try to keep one thread going instead of creating a new "answer" each time. NiFi supports the following browsers:
Mozilla Firefox: current & current - 1 Google Chrome: current & current - 1 Microsoft Edge Safari 8 The version of Firefox you are using is pretty old. If you upgrade to the current Firefox version or try using teh current version of Chrome instead, do you still see the same behavior? Thanks, Matt
... View more
11-09-2016
03:44 PM
@Vinod Chhabria What browser and version are you using?
... View more
11-09-2016
03:11 PM
Processor have not notion of what processors come before or after them in a dataflow. A processor simply has an establish set of rules governing its configuration. For example: Required properties XYZ must be set, all downstream relationships must be defined, and/or at least one upstream connection must be connected. So in the case of the ReplaceText processor it does not know who the source of the upstream connection is. It simply cares that one exists from which to pull FlowFiles from its queue.
... View more
11-09-2016
02:56 PM
1 Kudo
@Vinod Chhabria What you are trying to do definitely works. What version of NiFi/HDF are you using? Is this a standalone NiFi or a cluster?
When you drag the connection from ConsumeKafka to ReplaceText are you seeing any component get highlighted green including the ConsumeKafka processor itself? If so, without letting go of the mouse button drag you cursor back over the ConsumeKafka and then back to the ReplaceText. Did the highlighting of the ConsumeKafka go away? Did ReplaceText now highlight? Thanks, Matt
... View more