diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/ftp/LoadFromFtpToHDFS.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/ftp/LoadFromFtpToHDFS.scala index fccd4b9..96077a7 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/ftp/LoadFromFtpToHDFS.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/ftp/LoadFromFtpToHDFS.scala @@ -92,7 +92,6 @@ class LoadFromFtpToHDFS extends ConfigurableStop { throw new Exception("File path error") } - }else{ downFile(ftp,ftpFile,HDFSPath) }