Hi All, I have a NiFi dataflow on a standalone NiFi instance, with a custom processor that is a modified version of the ListenTCP processor; the NiFi instance is ingesting data from an external system, which pushes the data to NiFi instance. I made a copy of the dataflow, and by mistake I had both dataflows running (the original and the copy), which resulted in an error, possibly because both dataflows were trying to read data on the same port on the ListenTCP processor. Is this the expected behavior (failing) or it should have worked load balancing the incoming data between the 2 dataflows ? I understand the proper way to load balance is to ingest the data only once on the primary node and using a RPG distribute the data across the nodes in the cluster. Second question I have is, I stopped the original dataflow and started to run the copy, but now the data ingestion is not working, with an unusual error shown in the log - java.lang.NumberFormatException: For input string:"2147486900"; the string the error is pointing to does not exist in the incoming data from the external system; and the number in the error message seems to increment with each occurrence of the error in the log, like "2147486900", "2147487000", "2147487100",.... Any thoughts on what could be causing this error: Thanks in advance. ... View more

Hi All, I'm trying to have NiFi Provenance data from the NiFi cluster sent to a standalone NiFi instance. Both NiFi instances are unsecure; I followed the instructions in this post - https://community.hortonworks.com/articles/72727/extracting-nifi-provenance-data-using-sitetositepr.html My setup is shown below; I modified the site-to-site properties in nifi.properties file of the Provenance instance and setup the SiteToSiteProvenanceReportingTask on the NiFi Cluster, the properties of that are listed in the image below; When I start the SiteToSiteProvenanceReportingTask, I see the "Connection refused" error in the 2nd picture below; Any help is appreciated. Thanks, ... View more