Member since
04-29-2016
192
Posts
20
Kudos Received
2
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
1678 | 07-14-2017 05:01 PM | |
2845 | 06-28-2017 05:20 PM |
01-26-2017
03:00 PM
Hi @Timothy Spann, this is an old post of yours, but I've a similar need as you posted here; I wanted to know if you were able to come up with a working version of a dataflow that queries NiFi API provenance events; if you did, I appreciate if you could share some info about that. Thanks in advance.
... View more
01-26-2017
01:53 PM
Thanks @Balakrishnan Ramasamy; didn't know about the 'error' attribute on failed flowfiles.
... View more
01-23-2017
10:02 PM
Hello, We're logging failed flowfiles to local file system; when reviewing the failed flowfiles, there is no information to tell us at which processor a flowfile failed; I was thinking about tagging the flowfiles at each processor, with the processor name it's about to enter; and when logging the failed flowfile, embed this tag/attribute into the file name; so looking at the file name you could tell at what processor the flowfile failed; I'm sure this is not the best way, so any suggestions on how to do this better. Thanks.
... View more
Labels:
- Labels:
-
Apache NiFi
01-23-2017
06:23 PM
Thanks @Pierre Villard, I'll look at the example you provided. Just want to make sure I understood you correctly regarding ListenTCP; you're saying it's better for each node to listen to a port for incoming data in a HA, so if the sending system is sending data to one IP address, then we need a load balancer system/server that ingests that data and distributes it (in round robin or other fashion) to the various NiFi nodes; is that right ?
... View more
01-23-2017
01:13 AM
Hello, We are about to move to a NiFi cluster environment from a Standalone NiFi instance; we did our dataflow development on the Standalone instance; looking at the NiFi Admin documentation, it appears that some of the processors we have in our dataflow need to be configured to work in a cluster environment; From the admin guide... "...In a NiFi cluster, the same dataflow runs on all the nodes. As a result, every component in the flow runs on every node. However, there may be cases when the DFM would not want every processor to run on every node. ...the GetSFTP processor pulls from a remote directory, and if the GetSFTP on every node in the cluster tries simultaneously to pull from the same remote directory, there could be race conditions. Therefore, the DFM could configure the GetSFTP on the Primary Node to run in isolation, meaning that it only runs on that node. It could pull in data and -with the proper dataflow configuration- load-balance it across the rest of the nodes in the cluster...." We have GetSFTP and ListenTCP that fall into this case mentioned above; the verbiage above, from Admin guide, in bold, alludes to "with the proper dataflow configuration", the data from these processors can load balance across the nodes, but it didn't say what configuration is needed to be done; any suggestions or guidance is greatly appreciated. I'm thinking that PutHDFS processor does not need any special configuration for a Cluster environment, since on each node, it can write to HDFS whatever data is sent to it (from the dataflow on that node) and no coordination is needed between the PutHDFS processors running on the various nodes. Is my assumption correct ? I did find some guidance on how to configure PutEmail in a cluster environment. Thanks in advance.
... View more
Labels:
- Labels:
-
Apache NiFi
01-22-2017
01:22 AM
thank you @kkawamura for the heads up on the new processor.
... View more
01-19-2017
04:16 PM
thanks @Pierre Villard; it's good to know it's in the works.
... View more
01-19-2017
04:06 PM
as @Pierre Villard mentioned above, MonitorActivity processor can tell you when there is no activity for a specified period of time.
... View more
01-19-2017
04:04 PM
@Pierre Villard I understand there's no completion when we're streaming. But if we're moving static set of data from a database to HDFS or from Unix to HDFS/Hive, it would be handy if you can get an alert saying the job is complete. MonitorActivity processor would work for my use case. Thanks.
... View more
01-19-2017
02:56 PM
Hello, I'm looking for some ideas on getting notified when a NiFi job is completed, i.e. processed all the data from the source. Thanks.
... View more
Labels:
- Labels:
-
Apache NiFi