WilliamTan778 opened a new issue, #6070: URL: https://github.com/apache/seatunnel/issues/6070
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened FTP SOURCE, PATH IS NOT FOUND ### SeaTunnel Version dev version ### SeaTunnel Config ```conf { "env": { "execution.parallelism": 2, //仅支持BATCH 批处理操作 "job.mode": "BATCH", "checkpoint.interval": 10000 }, "source": [ { "plugin_name": "FtpFile", // 这个作为流程中的别名 "result_table_name": "tableA", "host":"172.30.13.179", "port":"2121", "user":"firewolf", "password":"P@ssw0rd01!", // 数据格式类型 "file_format_type":"csv", // 字段分隔符 "delimiter":",", "path":"/data.csv", "schema":{ "fields":{ "id":"int", "job_id":"int", "node_id":"string", "name":"string" } } } ] } ``` ### Running Command ```shell curl --location 'http://172.30.13.177:5801/hazelcast/rest/maps/submit-job' \ --header 'Content-Type: application/json' \ --data-raw '{ "env": { "execution.parallelism": 2, //仅支持BATCH 批处理操作 "job.mode": "BATCH", "checkpoint.interval": 10000 }, "source": [ { "plugin_name": "FtpFile", // 这个作为流程中的别名 "result_table_name": "tableA", "host":"172.30.13.179", "port":"2121", "user":"firewolf", "password":"P@ssw0rd01!", // 数据格式类型 "file_format_type":"csv", // 字段分隔符 "delimiter":",", "path":"/data.csv", "schema":{ "fields":{ "id":"int", "job_id":"int", "node_id":"string", "name":"string" } } } ] }' ``` ### Error Exception ```log org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-03], ErrorDescription:[Get file list failed] - Get file list from this path [/SaaS(多租户)化设计与实现.docx] failed at org.apache.seatunnel.connectors.seatunnel.file.ftp.source.FtpFileSource.prepare(FtpFileSource.java:88) ~[?:?] at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:84) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:309) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:182) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.RestJobExecutionEnvironment.getLogicalDag(RestJobExecutionEnvironment.java:76) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.RestJobExecutionEnvironment.build(RestJobExecutionEnvironment.java:99) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handleSubmitJob(RestHttpPostCommandProcessor.java:138) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:77) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:55) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at com.hazelcast.internal.ascii.TextCommandServiceImpl$CommandExecutor.run(TextCommandServiceImpl.java:402) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at com.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) ~[seatunnel-starter.jar:2.3.4-SNAPSHOT] Caused by: java.io.FileNotFoundException: File /SaaS(多租户)化设计与实现.docx does not exist. at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.getFileStatus(SeaTunnelFTPFileSystem.java:459) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.listStatus(SeaTunnelFTPFileSystem.java:406) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.listStatus(SeaTunnelFTPFileSystem.java:391) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.listStatus(HadoopFileSystemProxy.java:175) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.file.source.reader.AbstractReadStrategy.getFileNamesByPath(AbstractReadStrategy.java:93) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.file.ftp.source.FtpFileSource.prepare(FtpFileSource.java:85) ~[?:?] ... 15 more ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version 1.8 ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
