https://community.cloudera.com/t5/Support-Questions/can-we-list-flow-files-in-nifi-server-by-their-duration/m-p/292755#M216294 <P><a href="https://community.cloudera.com/t5/user/viewprofilepage/user-id/76030">@NY</a>&nbsp;</P><P>&nbsp;</P><P>Anything you can do via the NiFi canvas, you can also accomplish via the rest-api.<BR /><BR />So you can create a queue listing via a rest-api call:</P><LI-CODE lang="markup">curl http://&lt;nifi-hostname&gt;:&lt;port&gt;/nifi-api/flowfile-queues/&lt;connection-uuid&gt;/listing-requests</LI-CODE><P>The above call will return a response that includes the URL you need to use to retrieve those results.</P><P>for example:</P><LI-CODE lang="markup">http://&lt;nifi-hostname&gt;:&lt;port&gt;/nifi-api/flowfile-queues/&lt;connection-uuid&gt;/listing-requests/1d98d557-0171-1000-ffff-ffffd559ca47</LI-CODE><P><BR />Then query for the listings results</P><LI-CODE lang="markup">curl http://&lt;nifi-hostname&gt;:&lt;port&gt;/nifi-api/flowfile-queues/&lt;connection-uuid&gt;/listing-requests/1d98d557-0171-1000-ffff-ffffd559ca47</LI-CODE><P>This return a json with all the FlowFiles from that specific connection queue from all nodes in your NiFi cluster.&nbsp; That json would need to be parsed for info like nodes where the "lineageDuration" epoch time is x amount of time older then now, the "clusterNodeAddress" (which node holds the file), and maybe filename".</P><P><BR />and then delete the queue listing when done. (this is important or it stays around using heap space).</P><LI-CODE lang="markup">curl -X DELETE http://&lt;nifi-hostname&gt;:&lt;port&gt;/nifi-api/flowfile-queues/&lt;connection-uuid&gt;/listing-requests/1d98d557-0171-1000-ffff-ffffd559ca47</LI-CODE><P><BR />Hope this helps,<BR />Matt</P> Fri, 27 Mar 2020 20:20:16 GMT MattWho 2020-03-27T20:20:16Z