Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

problem with nifi listFTP offset

Solved Go to solution
Highlighted

problem with nifi listFTP offset

New Contributor

Hi, I'm in trouble with listftp processor, I need to process each new file on a FTP server, fetch and move to new folder with the date (year/month/day). sometimes listFTP offset reach the last file but the fetch doesn't move the file without errors and files start to accumulate. I can't fetch the file and move it because fetch doesn't create folder if doesn't exist, for this reason i used a putftpfile.

Somebody experienced the same problem?

79504-screenshot-1020019184-8080-20180717-16-11-49.png

1 ACCEPTED SOLUTION

Accepted Solutions

Re: problem with nifi listFTP offset

Master Guru
@federico dell'anese

-

The particular enhancement you are looking for here was coded in to Apache NIFi 1.7.0 version. Upgrading to this new version of NiFi will allow the FetchFTP processor to create move directories dynamically. The change was covered in the following Apache Jira:
https://issues.apache.org/jira/browse/NIFI-5090
-

Thank you,

Matt

-

If you found this Answer addressed your original question, please take a moment to login and click "Accept" below the answer.

2 REPLIES 2

Re: problem with nifi listFTP offset

Master Guru
@federico dell'anese

-

The particular enhancement you are looking for here was coded in to Apache NIFi 1.7.0 version. Upgrading to this new version of NiFi will allow the FetchFTP processor to create move directories dynamically. The change was covered in the following Apache Jira:
https://issues.apache.org/jira/browse/NIFI-5090
-

Thank you,

Matt

-

If you found this Answer addressed your original question, please take a moment to login and click "Accept" below the answer.

Re: problem with nifi listFTP offset

New Contributor

thanks Matt, it solves the problem :)