Nifi: how to convert multiple log file in one file?

I have many internal log , which i write myself inside nifi environment, i want to input all this data inside one log flowFile, but this code trows Null pointer exception what should i cahnge? import java.nio.charset.StandardCharsets; import org.apache.commons.io.IOUtils; import

Nifi:how to handle with multiple flowfiles?

I have request data which can be splitted into several flowfile for example request data for date 2017-02-02 can be splitted to four part 2017-02-02.1 ,2017-02-02.2 ( i use this partiotion because webservice uses paging and it can send only certain amount of data at a time (400 mb) and if

NIFI:how to handle paging in web service

I want to get service data which have paging logic like this: every time i send request, it can get only 700 mb data and if the response data for certain id is more than 700 mb i will have to invoke service twice, but if for certain id data is more than 2800mb i will have to invoke service four

Nifi:is it possible to use File Lock in nifi?

I want to use File lock and Thread sleep in nifi processor( ExecuteScript processor code) Can you link me any article or example of relative cases, now i use simple java file lock and thread sleepsbut when several (ExecuteScipt processor works at the same time)

nifi: How to update and trnaform xml file inside ExecuteScript processor

Question by sally sally 12 secs ago nifi-processorjavaapache-nifigroovy I want to read xml file from folder and i want to update it and make new flowfile(my code will be placed in nifi processor) which will containt this renewated data but i can't parse xml document properly i got error like

How to use Filelock in nifi?

I want to use filelock inside nifi ExecuteScript processor code ( i want to prevent reading and writing inside xml file by several processor), but i don't want to get lock exceptions (when two processor wants to read the same file) Should i use Thread.sleep() or any relative logic which is

Re: Nifi: how to remove session based on atribute value in nifi

It was helpful, thank you -- Sent from: http://apache-nifi-developer-list.39713.n7.nabble.com/

Nifi: how to remove session based on atribute value in nifi

I want to remove session in case i get certain data from file i have code like this,but i got errors "flowfile has already marked for removal", what should i change to get rid of extra errors? In case of session rollback flowfile will dissapear in queues also? 2.should i use rollback instead of

Nifi:how to handle flowfile data updateing and reitreving?

I want to reitreve data from folder and then update it and put it back to its' destination and i want to make this operation many times , here is my code i try to getfile and update it , but it doesn't roll back the file and can't reitreve data with the same filename(sometimes when i start this

Re: Nifi:How can i remove “.” from “.filename” in nifi custom processor

actually it never fiishes writing process i mean exceptions like this can't rename file ".conf.xml" -- Sent from: http://apache-nifi-developer-list.39713.n7.nabble.com/

Can't use renameTo in nifi custom processor code

One of the most important part of my code is that it should put file in folder. i use this code for renaming ".conf.xml" to "conf.xml" but it doesn't work properly: final Path rootDirPath = get("C://Users//user//Desktop//try2//nifi-1.3.0//1"); final Path

Can't rename ".file.xml" to "file.xml" in nifi custom code

I have this code inside my onTrigger method in order to rename file and then put it in folder but for unknown reasons i can't do it in log file i can't see any failure, error or warn. Mainly i want to make custom processor which get xml file from folder and then

Making log files in nifi

I want to make log files with this information:1.processor failure information,invokehttp(response and failures),puthdfs(succes,falure), deletting file from hdfs(sucess,falure) should i use custom logging or i have to make source logs? what is difference from nifi-app and nifi-user

Using EvaluateXpath in nifi

I have xml response like this : ;false -2 data ot found and I wan to get value of ErrorCode. I tried this: //Error/ErrorCode/text() but ErrorCode attribute seems to be Nan. Can you recommend me any solution? -- View this message in context:

Re: Using wait Processor in nifi

Yes i have added it, thank you for your replay -- View this message in context: http://apache-nifi-developer-list.39713.n7.nabble.com/Using-wait-Processor-in-nifi-tp16691p16717.html Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.

Using wait Processor in nifi

I need to use wait processor for terminating invokehttp processor in case of failure, I have tried this - [https://stackoverflow.com/questions/43915412/how-to-use-wait-notify-processor][1] and added

Re: Using GregorianCalendar in apache nifi

Is it possible to download apache-nifi open source project from github and then add "import java.util.GregorianCallendar" inside ExecuteScript.java code and then deploy project I have tried it but it throws errors what should i do? -- View this message in context:

Using GregorianCalendar in apache nifi

Is it possible to import java.util.GregorianCallendar in groovy script(in executescript processor)?and if it isn't possible what should i use instead of it? -- View this message in context: