Hi, I'm only able to do that via two processors: 1- JotlTransfomJSON : this is to add desired attributes (attr_id & attr_name) to the flowfile json using the following spec:   [ { "operation": "shift", "spec": { "#${attr_id}":"attr_id", "#${attr_name}":"attr_name", "model": "model", "cars_drivers": { "*": { "id": "cars_drivers[#2].id", "name": "cars_drivers[#2].name", "is_processed": "cars_drivers[#2].is_processed" } } } } ]   2 - UpdateRecord Processor: Once the attributes are added to the Json , you can update those records Is_processed value only when the id matches the attr_id and name matches the attr_name. To do that set the following properties:      a- Replacement Value Strategy: Literal Value      b- /cars_drivers[*]/id[.=../../../attr_id]/../name[.=../../../attr_name]/../is_processed : 1   Hope that helps, if it does please accept solution.   ... View more

Hi ,   Can you provide examples of the different json input? ... View more

Hi, Try the following Jolt spec:   [ { "operation": "shift", "spec": { "tags": { "*": { "tag": "tags.[#2].Parameter", "value": "tags.[#2].value" } } } } ] If you find this helpful please accept solution. ... View more

Hi, I dont think it matters which system the path is located as long you have access to it. Do you have access to the path \\10.1.1.35\nifi from the machine where nifi is deployed? I'm not Linux expert but you need to test if the path with the file name is accessible by doing some system command or trying to access via file explorer.   ... View more

Hi,   Have you looked into the ControlRate processor. Its not exactly doing what you want but it allows you to put a time to hold a flowfile before it gets released to the next processor. For example if you think that you need a second to process one flowfile from the moment its fetched to the moment its processed by PutKudu, then you can configure the ControlRate as follows:   ... View more