When you write a website with some links to other pages and maybe a form or two, you've already done real REST. The client (i.e. a web browser) presents the current resource to a user, automatically discovers related resources and allows the user to create/edit their own resources. Why people don't apply the same principles to the APIs they write is baffling. ... View more

@Chakkara  As far as i remember , distributed cache is not having consistency . You could use Hbase or HDFS for storing the status of success or failure of the processors for downstream application. Once you saved the Success and Failure at Hbase . You can retrieve it from the Hbase processor using the row ID.   Build a REST API  NiFi flow to pull the status from Hbase  for example    HandleHTTPRequest --> FetchHbaseRow - HandleHTTPResponse   You can call the HTTP API (Request and Response) via shell script/curl and call the script from Control-M.  ... View more

@Chakkara, if the solution provided by @ashinde resolved your issue, can you please mark it as the solution?  It will make it easier for others to find the answer in the future.   ... View more

Thanks for the response and it works!!  ... View more

Some examples https://community.cloudera.com/t5/Support-Questions/How-Extract-text-from-a-multiline-flow-and-create-only-one/td-p/104706   https://nathanlabadie.com/recombining-multiline-logs-with/   https://github.com/tspannhw/EverythingApacheNiFi/blob/main/README.md ... View more

Use UpdateRecord (csv reader, json writer) to change date PutDatabaseRecord to save to oracle   https://www.datainmotion.dev/2020/12/simple-change-data-capture-cdc-with-sql.html https://www.datainmotion.dev/2019/10/migrating-apache-flume-flows-to-apache_15.html https://www.datainmotion.dev/2021/01/flank-real-time-transit-information-for.html https://www.datainmotion.dev/2020/12/smart-stocks-with-flank-nifi-kafka.html https://github.com/tspannhw/EverythingApacheNiFi https://www.datainmotion.dev/2021/03/processing-fixed-width-and-complex-files.html https://www.datainmotion.dev/2020/06/no-more-spaghetti-flows.html   ... View more

@Chakkara  More detailed would be needed before I would know if I can offer any advice here. Can you share: 1. PutDatabaseRecord processor configuration 2. Assuming you are using the CSVReader, please share its configuration 3.  DBCPConnectionPool configuration 4. Complete Exception including any stack trace if exist form nifi-app.log. 5. Any data manipulations made between your GetFile and PutDatabaseRecord processors? 6. Sample input file would also be very helpful. Thanks, Matt ... View more