The error message was not very clear but it works for HDF 1.9.2. Thanks a lot! ... View more

I think this may be a bug in the NIFI JoltTransformRecord processor. What is the best way to register this bug? ... View more

Hi Matt. Works like a charm, thanks for your help! ... View more

Thanks @Former Member. Actually Jolt Transformation is the the solution worked for me (reached few days ago, I'm looking for time to write my answer 🙂 ). In my flow I route on an attribute if I want the payload or not and then I apply this Jolt spec: [{     "operation": "shift",     "spec": {       "headers": "headers",       "info": "info",       "payLoad": "payLoad"     }   }, {     "operation": "default",     "spec": {       "_kafka": {         "offset": "${kafka.offset}",         "partition": "${kafka.partition}",         "topic": "${kafka.topic}",         "key": "${kafka.key}"       },       "_nifi": {         "flowfileuuid": "${uuid}"       }     } } ] Thanks to confirm this is the right way: I'm a newer to NiFi. ... View more

Thanks,Matt! Sorry for a late answer 🙂 ... View more

Thanks Matt for pointing this out. Seems I had read the documentation too quickly : From executeSQL usage : sql.args.N.type Incoming FlowFiles are expected to be parametrized SQL statements. The type of each Parameter is specified as an integer that represents the JDBC Type of the parameter. sorry ! ... View more

Thanks, now I can load from local ... View more

Hi, Matt! very useful and informative articles. Thank you veru much! Could you tell me how do I read content of a flowFile, transform it the way I like, and write the output to a new flowFile attribute (not back to the content)? I was trying to return transformation result from the callback but caught the error: None required for void return which is fairly expected behaviour - callback returns to the session.read function, but the latter does not return anything, I assume. So we get the flowFile itself and its content residing in different namespaces and I can't figure out how can I use content of the flowFile to place it into the attribute. Could you kindly help me, Matt? ... View more

Very interesting article, well done ! Have you done something similar with jython? I'm currently trying to use an execute script, with jython, to put key/values onto the distributed map cache but can't find a way to do it... BR, Paulo Rente ... View more

now use record processor ... View more