Hello, I cannot connect my NifiStorm java class to my NiFi instance. I get an exception error "Could not find port with name portName for remote NiFi instance". My NiFi instance is running with the port name = "portName" and Ambari reports that the DRPC server, nimbus, and the UI Server has started. It also reports that the Supervisor is live. I have Storm on my sandbox - HDP 3.2. What could be causing this unrecognized port name error? ... View more

I would like to get all of the NiFi provenance data in my project and store it within a file using a custom NiFi processor, but I cannot find a working solution. Does anyone know how I can get this done? The code should be written in the custom processor's onTrigger method block. ... View more