Hi, What is the exact line of code you have? It let me think that you would like to save the content of your RDD/DF/DS but you are calling this method although you are not manipulating such an object anymore. ... View more

Hi, I think this is the information you are looking for: https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#provenance-repository ... View more

Hi, The recommended way is to use GenerateTableFetch as input processor of QueryDatabaseTable processor. It generates flow files with SQL query to execute. This way, it also allows you to balance the load if you are in a NiFi cluster. In this processor, you can set the partition size to limit the number of rows of each request. The error you have suggests something different. Maybe the JDBC driver is not fully implemented and is not supporting the properties of this processor. But it does sound to me like a memory issue. Have a try with GenerateTableFetch. ... View more