I have an Avro which uses another record type and fixed type Avro as fields types. I have all of them in the schema registry: [ {  "type": "fixed",  "name": "uuid",  "size": 16 }, {  "type": "record",  "name": "ParamValue",  "fields": [   {    "name": "values",    "type": {     "type": "map",     "values": [      "null",      "boolean",      "int",      "long",      "float",      "double",      "bytes",      "string",      "uuid",      {       "type": "array",       "items": [        "boolean",        "int",        "long",        "float",        "double",        "bytes",        "string",        "uuid",        "ParamValue"       ]      },      "ParamValue"     ]    }   }  ] }, {  "type": "record",  "name": "Action",  "fields": [    {    "name": "modifiedBy",    "type": [     "null",     "uuid"    ],    "default": null   },    {    "name": "parameterValues",    "type": "ParamValue",    "default": {     "values": {}    }   }  ] } ] I am trying to convert the Serialized Action Instance Avro to JSON using NIFI convert record processor but getting below error java.lang.IllegalArgumentException: Cannot set the default value for field [parameterValues] to [{values={}}] because that is not a valid value for Data Type [RECORD]     at org.apache.nifi.serialization.record.RecordField.<init>(RecordField.java:65)     at org.apache.nifi.avro.AvroTypeUtil.addFieldToList(AvroTypeUtil.java:630)     at org.apache.nifi.avro.AvroTypeUtil.createSchema(AvroTypeUtil.java:474)     at org.apache.nifi.avro.AvroTypeUtil.createSchema(AvroTypeUtil.java:444)     at org.apache.nifi.avro.AvroTypeUtil.createSchema(AvroTypeUtil.java:435)     at org.apache.nifi.avro.AvroReaderWithEmbeddedSchema.<init>(AvroReaderWithEmbeddedSchema.java:38)     at org.apache.nifi.avro.AvroReader.createRecordReader(AvroReader.java:100)     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)     at sun.reflect.DelegatingMethodAccessorImpl.invoke(Delega For simple Avro's, the convert record processor is working but it is failing for this Avro conversion. ... View more

I am implementing a scenario where I am fetching data from HBase using Scan Processor and then I delete those data and do other things. When no data is found during the HBase scan the processor does not let the flow continue and as a result, remaining processors do not get called. I tried using the original here, but the downside to is if the data is present the other processors are called twice. First time for Original and second time for success. Is there any way I could prevent the other processors getting called twice? ... View more

Hi, I am using SiteToSiteClient to connect to my nifi and to initialize the site to site client , I pass the urls(http//IP:8080/nifi) and port name (Name of the input port) in my spring boot Rest service. When I run this on my local, the service connects to nifi. But when I deploy it to linux server the service tries to connect to port 10000 instead of 8080. ... View more

I am new to Nifi, I am trying to create a process group which takes an authentication token using get port and makes call to Api. I have used Httpprocessor to fetch the data, after fetching the data I am taking some data, let's say an I'd using EvaluateJSONPath and passing it to a new hero processor to fetch some other data. But I am not able to pass the token that I received at the very start of the process group. Is there any way I can set the token received global for all process in processorgroup ?? We can set a global variable for processorGroup but can it's value be made dynamic instead of static ?? ... View more