We require a standard way to delay an incoming flowfile processing for fixed interval. Right now, we are creating a local attribute, which stores the time to expire and we keep checking that variable value with current time to get that achieved. This solution creates bottleneck with large traffic. Please share your thoughts in achieving the same. Thanks for your help in advance. ... View more

NiFi attributes while processing trims the String ending with spaces. Please specify if we can preserve the spaces by config/alternate route so that it can we preserved and utilized in further processing ... View more

While working with Nifi to ingest data over Hadoop, it required some row updates to be performed on particular event through update statement in Hive. I tried to execute the query through putHiveQL processor and its failing with write conflict error. PFB error that is being observed. Please note that I tries to add transnational concurrency params to processor but it did not allowed me to do so suggesting as invalid props. Please let me know how to handle update transactions through Nifi. We have events coming for same records in parallel and need to have update only to handle business reuirement. ... View more