Hello, I am observing quite strange behaviour of anyDelineatedValue expression when I use it with 'OR' operation. If I use 'AND' operation there is no issues. Input attribute value: org.entitlement.list=AA,CC,DD,FF Expression used in RouteOnAttribte/UpdateAttribute processor : ${anyDelineatedValue("${org.entitlement.list}", ","):equals('BB'):or(${anyDelineatedValue("${org.entitlement.list}", ","):contains('EE')})} Above expression is giving ArrayIndexOutOfBoundException for OR operation for the given input (where both the values which expression is looking is not present) If I use 'AND' operation expression works fine. What is the difference here? If I pass BB or EE in the input then expression wont give exception ! Looks like defect, can some one please suggest if anything wrong in this? Thanks Mahendra ... View more

Hello, I have a scenario where I need to check for string contains, but for exact match of comma separated words. Example String: example = "US,UK,IN,NOT_APPLICABLE" I want to check above string contains specific word like 'US' or 'LE' Case 1: example.contains('US') . - expecting TRUE Case 2: example.contains('LE') - expecting FALSE If I use normal :contains(), case 2 will also return TRUE since 'LE' is part of 'NOT_APPLICABLE' But I want to check contains for comma separated values strictly. Is there any easy way to achieve this? Thanks, Mahendra ... View more

Hello, I have below json as flowfile content - { "organization_id": "life-360", "message_type_id": "MSG01", "consent_required": "1", "country_list": [ "GB", "IT", "BG" ] } I want below content as output - GB, IT, BG I am able to get "country_list": [ "GB", "IT", "BG" ] in flow file using JOLT but not comma separated country list. Could any one please help with best way? Thanks, Mahendra ... View more

Hello , I have a scenario where I need to run a processor on NiFi restart. Is there any way to trigger a nifi processor whenever nifi restarts ? Thanks in advance, Mahendra ... View more

Hello All, I have requirement of caching some information in nifi and which should be used for every flow file validation (more than 1000 per second). I am thinking to store information in Cassandra table and update that to Nifi cache every 24 hours or so.. (Nifi cache update using PutDistributedMapCache processor) But problem is how to hold/re-load cache value when Nifi restarts due to various reasons.. I also want to understand where these cached message will be stored actually in multinode cluster nifi. Thanks in advance. Thanks, Mahendra ... View more