@mayki wogno I have tested RFA appender for Falcon logs . Please make below changes in Falcon log4j.xml .(Example - Metric logs) <appender name="METRIC" class="org.apache.log4j.RollingFileAppender"> <param name="File" value="${falcon.log.dir}/${falcon.app.type}.metric.log"/> <param name="Append" value="true"/> <param name="Threshold" value="debug"/> <param name="MaxBackupIndex" value="10"/> <param name="MaxFileSize" value="2048"/> <layout class="org.apache.log4j.PatternLayout"> <param name="ConversionPattern" value="%d %m%n"/> </layout> </appender> You can set MaxBackupIndex(Number of files) and MaxFileSize(Size in Bytes) as per you environment. Also, You can set it similarly for other logs like audit logs etc. ... View more

@mayki wogno user defined arguments aren't really sent to ExecuteScript. If the value of the `filename` attribute is needed, it can be retrieved from the flow file itself. Below is an example of how to retrieve the `filename` attribute, update the attribute, and send the flow file to a `success` relationship. flowFile = session.get() if (flowFile != None): filename = flowFile.getAttribute("filename") flowFile = session.putAttribute(flowFile, "filename", filename + "new_name") session.transfer(flowFile, REL_SUCCESS) For an example that is a little more in depth, you can download a template from this gist. For a deeper look into developing with NiFi, please see the developer's guide. ... View more

If you do a GET for the root group using /process-groups/{id} then that response will have all the other process groups under it, you can look at the ProcessGroupEntity example JSON response, and then component -> contents -> processGroups or processors. The root group id won't change so that should be your starting point. ... View more