Re: deploy nifi registry via blueprint

Hey Georg, You probably want to ask the vendor that provides HDF about how to do this. Maybe a good question for https://community.hortonworks.com Thanks, Bryan On Thu, Feb 8, 2018 at 1:04 AM, Georg Heiler wrote: > Hi, > > I have an ambari 2.6.1 with HDP 2.6.4 and HDF 3.1 management pack inst

ConvertRecord

All, I am trying to convert an avro record taken from a QueryDatabaseRecord processor and convert it into a json. I am trying to do this with the convert record processor using the avroreader and jsonrecordsetwriter controller services. My avro schema is being inferred by the avroreader and my json

Re: ConvertRecord

Austin, What version of NiFi are you using? I'm wondering if you're running into [1] (fixed in 1.3.0), or [2] (fixed in 1.4.0), or something else. You may want to change the types to be "optional", meaning a union between null and the intended type. So for "PracticeId", try: {"name": "PracticeId"

Re: Integrate new flowFile generation out of an ExecuteScript processor running a python script

Matt, thanks very much for all your help. I tried to embed the session.create() and the session.transfer() into the loop that crunches through the files. The ExecuteScript processor that runs my python script does not throw any error, but no flowFiles result in the REL_SUCCESS output queue. I've re

Help on NiFi RecordPath

Hey there, I've been trying to use RecordPath to retrieve information, but I'm a bit stuck. Have a complex schema that involves records and maps. This is my Avro Schema: { "type": "record", "name": "Contact", "fields" : [ {"name": "id", "type": "string"}, {"name": "firstName", "type

Re: Help on NiFi RecordPath

Leandro, I think you’re super close! You should be able to use: /attachments/values[*]/value Sent from my iPhone On Feb 8, 2018, at 7:29 PM, Leandro Lourenço mailto:leandrohlsi...@gmail.com>> wrote: Hey there, I've been trying to use RecordPath to retrieve information, but I'm a bit stuck. H

Create nested records

Hi, I'm having trouble taking a flat record and building an avro schema that lets me nest it. I found this example schema, but after using a ConvertRecord or UpdateRecord, I receive the equivalent of [{"parent" = null}] {"type": "record", "name": "CustomerInput", "namespace": "org.apache.example"