Hi Is there a way that I can extend ListSFTP as a custom processor to allow inward connection somewhere like this @InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED) public class ListDynamiscSFTP extends ListSFTP { // ... }  Iam completely new to Nifi and not able to identify how to implement this code further ... View more

Hi,   we recently started evaluating apache nifi for our use cases.   Here is one of such sample pipe line that we have constructed we have two processed one is Getfile which checks for files present in a local folder. Once they are available it sends them to the execute stream command.    In  execute stream command we want to send file that we received from getfile step to a remote linux server. The destination linux server doesn't have an FTP server hence cant use putFTP. This is the command I want to execute to transfer the file sshpass -p '123' rsync -avz -e ssh --ignore-existing "${filename}" test@172.172.172.172:/home/test/nifioutput   Here is the configuration for execute stream command  log file Any help would be greatly appreciated.     Regards Lakshmi Tharun.   ... View more