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

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

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

Apache Nifi - How do I change a value of a window variable during a workflow? Which processor should I use? What syntax? ... View more

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

Hi, please, how to add a tag at the beginning of json with JoltTransformJson? In the attached image I added a tag to the end of json, what syntax to add at startup? ... View more

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

Hello! The stream below gets a get into an ftp and then distributes these files to a spark cluster, however, realize that PutSFTP 1 has just picked up 3 files out of the 7 that came out of the GetFTP processor. Please, what is the cause of this problem? Do I need to configure something in NIFI? Nifi is at its default setting. Each FTP file has 1.6 GB media packed. Nifi is installed on the master node of Spark, the cluster has 3 with 44 cores per in and 256 in memory. How should I proceed? Thank you! ... View more

Hello, what is the procedure for retrieving all files from getfile? Note that getfile has 8 files, however, only two are caught by putfile? Is it due to size? The files have on average 1.7 GB compressed and 19 GB uncompressed. Please, can someone please send me the correct procedure? Thanks! ... View more

Hello, how do I configure the PutMongo processor to perform an update on a mongodb collection? The following error occurs. NiFi version I use: NiFi 1.7.1 ... View more