I have a pipeline running on a daily basis, I wish to receive an email alert whenever any of the processor fails. I tried testing put email processor, I am receiving success flow files after PutEmail but email is not being generated despite entering correct SMTP details. Kindly suggest if I am missing on anything.  My nifi pipeline flow is as follows : getMongo > flatteJson > evaluateJsonPath > attributeToJson > queryRecord > updateAttribute > PutS3 For eg : If I get an error in QueryRecord : column 'x' not found in list of columns. This failure alert should be sent on my email. PFB the properties I have used for configuration of PutEmail processor   ... View more

I am trying to write the below query in getMongo processor   {"updatedAt" : {$gt : 2022-12-10}} But it is showing an error stating that query is not a valid JSON representation. I tried adding double quotes as well but when I run it, it doesn't show any error nor any results in success, failure or original nodes.   My end goal is to fetch incremental data i.e. only the new data added daily (day -1) using "updatedAt" field. Kindly help me with this  ... View more