Member since
03-12-2018
2
Posts
0
Kudos Received
0
Solutions
10-29-2018
05:27 PM
@Matt Clarke Can you explain (or maybe pointing to references) about this statement "Also keep in mind that the memory used by NiFi's dataflows can and often does extend beyond just heap"? I'm experiencing this one, i set my heap 80% of total memory, yet the monitoring team reported that the total memory has been drained until 95 - 98%... My heap allocation is 8GB - 24GB for total memory 32GB; I seem can't find clear explanation about Nifi high memory utilization aside from this one Thanks, Bobby
... View more
03-12-2018
08:26 AM
Good day, I have created dummy flowfile with certain structures like below {"created_at":"Mon Mar 12 14:30:50 ICT 2018",
"id_message":455,
"msisdn":854,
"body":"hello world",
"sender":"asura",
"rule":"false"}
Now, i also have created a record in mongodb which contains: _id:5aa608dab183163784c3f7dd
rule:"${anyAttribute("body"):contains("world")}"
action:"route"
destinations :"moon"
My purpose is, for each flowfile, evaluate using rule attributes in database record, and if it is matched, then add "action" and "destinations" as additional record attributes, in short, the final record might looks like this. {"created_at":"Mon Mar 12 14:30:50 ICT 2018",
"id_message":455,
"msisdn":854,
"body":"hello world",
"sender":"asura",
"rule":"true",
"action":"route"
"destinations" :"moon"
}
I have tried with below schema and even hardcoded the EL into lookup record processor, but still ended up failed Where do i go wrong? Worst case i might implement custom processor Thank you
... View more
Labels: