Member since
08-04-2018
26
Posts
0
Kudos Received
0
Solutions
12-26-2018
03:40 AM
Hello, I use a counter in my stream with the publish name, however, I need to clear this counter after sending the trailler to rabbitmq. Please, what is the best way to do this procedure by Nifi? The portion of the stream is in the attached image.
... View more
Labels:
- Labels:
-
Apache NiFi
12-13-2018
11:06 PM
Please, I need to serialize a text / plain into a json quickly because of the amount of records I have in my workflow, I tried to use the one executescript / jython processor, however, it got very slow due to the json.dumps () class. Please, what is the most performatic way in Nifi to serialize Json? Can you send an example?
Thank you!
... View more
Labels:
- Labels:
-
Apache NiFi
12-13-2018
05:04 PM
Hello, I was working with the nifi.1.7.1 version, I updated it to version 1.8.0, however, there is now the error mentioned in the attached image at the time of publication for the AMQP. This processor works correctly in version nifi.1.7.1. Is there a procedure to be performed or is it a BUG version 1.8.0? Thank you!
... View more
Labels:
- Labels:
-
Apache NiFi
12-12-2018
06:35 PM
Shu, I did the way you suggested and yet the value comes empty. I need to save the value of a property at the beginning of my stream to reuse it in my ReplaceText processor according to the attached image. After GetMongo I lose this property. Please, what is the best way to perform this procedure in NIFI?
... View more
12-12-2018
04:56 PM
Matt, I mean a group variable. In my flow, I need to save the value of an attribute at the beginning of the stream to reuse it from the middle of the stream in processor ReplaceText, after a GetMongo processor, however, after I create the variable I can not update the value of that variable. I also tried to save the content of this attribute in state value, however, I can not retrieve it later. Look at this example in the attached image. Thank you!
... View more
12-12-2018
02:14 PM
Apache Nifi - How do I change a value of a window variable during a workflow? Which processor should I use? What syntax?
... View more
Labels:
- Labels:
-
Apache NiFi
12-12-2018
02:16 AM
Hello, I'm storing the value of the file property, however, when I time retrieve it with the getStatevalue command in the UpdateAttribute processor the property appears empty. Please, what is the cause of this problem? Look at the attached image. Thank you!
... View more
Labels:
- Labels:
-
Apache NiFi
11-26-2018
07:34 PM
Shu, I realized that the Listfile processor did not pick up the same file more than once, even clearing the status. For example, I had processed file1.gz and moved it to another directory, stopped all processors, cleared the status of ListFile and UpdateAttribute, and restarted processing, and even then the ListFile processor did not pick up file1.gz again. Does Nifi store the reference with this file name in some directory of it that I should delete? Thank you!
... View more
11-24-2018
09:40 PM
Shu, I read the article https://community.hortonworks.com/articles/191080/trigger-basedserial-data-processing-in-nifi.html but I did not understand how the RouteOnAttribute processor was configured. Apparently the firstFF property was created, however, I did not see the value of this property in the article? Could you please send a simple example of how to process a list of files, one at a time with the wait and notify processors? Thank you!
... View more
11-20-2018
01:36 AM
Shu, please, what is the procedure for processing one file at a time? After unpacking, my files get huge and fill my disk. Is there any configuration in the processor or do I need to restructure my flow? Thank you!
... View more
Labels:
- Labels:
-
Apache NiFi