Hello Everyone I had created one processor group . there are few processor in my flow which might have some property to change dynamically as per user's request . I am thinking to provide them GUI with only those set of property without giving access to entire nifi flow. This GUI interface will change the flow.xml.gz file but the problem is that after changing the flow file configuration when i am opening the nifi those changes are not reflecting. Can someone suggest what should i do ? Thanks ... View more

Hello Team kapacitor is triggering the alert and sending the data to kafka. and kafka is getting the message as below . {"id":"system_load1:nil","message":"CRITICAL: system_load1/facrs has high cpu load: 1.35","details":" ","time":"2018-09-24T06:24:50Z","duration":0,"level":"CRITICAL","data":{"series":[{"name":"system_load1","tags":{"host":"facrs"},"columns":["time","value"],"values":[["2018-09-24T06:24:50Z",1.35]]}]},"previousLevel":"CRITICAL","recoverable":true} and i am using cosumekafka processor to consume the data and process is further using update record. i am using below schema in jsontreereader but its not working. Kindly suggest { "title": "The Root Schema", "required": [ "id", "message", "details", "time", "duration", "level", "data", "previousLevel", "recoverable" ], "properties": { "id": { "type": "string", "title": "The Id Schema", "default": "", "pattern": "^(.*)$" }, "message": { "type": "string", "title": "The Message Schema", "default": "", "pattern": "^(.*)$" }, "details": { "type": "string", "title": "The Details Schema", "default": "", "pattern": "^(.*)$" }, "time": { "type": "string", "title": "The Time Schema", "default": "", "pattern": "^(.*)$" }, "duration": { "type": "integer", "title": "The Duration Schema", "default": 0 }, "level": { "type": "string", "title": "The Level Schema", "default": "", "pattern": "^(.*)$" }, "data": { "title": "The Data Schema", "required": [ "series" ], "properties": { "series": { "type": "array", "title": "The Series Schema", "items": { "title": "The Items Schema", "required": [ "name", "tags", "columns", "values" ], "properties": { "name": { "type": "string", "title": "The Name Schema", "default": "", "pattern": "^(.*)$" }, "tags": { "title": "The Tags Schema", "required": [ "host" ], "properties": { "host": { "type": "string", "title": "The Host Schema", "default": "", "pattern": "^(.*)$" } } }, "columns": { "type": "array", "title": "The Columns Schema", "items": { "type": "string", "title": "The Items Schema", "default": "", "pattern": "^(.*)$" } }, "values": { "type": "array", "title": "The Values Schema", "items": { "type": "array", "title": "The Items Schema", "items": { "type": "string", "title": "The Items Schema", "default": "", "pattern": "^(.*)$" } } } } } } } }, "previousLevel": { "type": "string", "title": "The Previouslevel Schema", "default": "", "pattern": "^(.*)$" }, "recoverable": { "type": "boolean", "title": "The Recoverable Schema", "default": false } } } ... View more

i am trying to convert below json data generated by kapacitor using nifi . But i am getting huge issue. Can someone plz help me to get the avro schema of the below jason data. {"id":"system_load1:nil", "message":"system_load1:nil is CRITICAL", "details":"{.message}", "time":"2018-09-21T12:44:10Z", "duration":0, "level":"CRITICAL", "data":{ "series":[ {"name":"system_load1", "tags":{"host":"ilcepoc560"}, "columns":["time","value"], "values":[ ["2018-09-21T12:44:10Z",3.43] ] } ] }, "previousLevel":"CRITICAL", "recoverable":true } ... View more

I am having following json output coming from Executeinfluxdbquery {"results":[{"series":[{"name":"system_load1","columns":["time","host","value"],"values":[[1.5374502E18,"ilcepoc555",12.79],[1.5374502E18,"ilcepoc556",3.56],[1.5374502E18,"ilcepoc557",1.83],[1.5374502E18,"ilcepoc559",4.68]]}]}]} And i am using splijson to create multiple flow file but it is generating 4 flow file of same output [1.5374502E18,"ilcepoc559",4.68] . I am using $.results[0].series[0].values.* in Jasonpathexpression property. ... View more