我有一个使用 Akka Streams 的 Scala 应用程序。因此,我的应用程序的流程如下:
1. Check if file exists on FTP - I'm doing it with the org.apache.commons.net.ftp.FTPClient
2. If it exists stream it via alpakka library(and make some stream transformations)
我的应用程序在本地工作,可以连接到服务器。
问题是当它被部署到dcos/mesos时,我遇到了一个问题:
java.io.IOException: /path/file.txt: No such file or directory
我可以确定文件仍然存在。此外,当我尝试通过ftp在docker容器中本地连接时,会出现以下情况:
ftp> open some.ftp.address.com
Connected to some.ftp.address.com.
220 Microsoft FTP Service
Name (some.ftp.address.com:root): USER
331 Password required
Password:
230 User logged in.
Remote system type is Windows_NT.
ftp> dir
501 Server cannot accept argument.
ftp: bind: Address already in use
ftp>