wells-ll opened a new issue, #11595: URL: https://github.com/apache/seatunnel/issues/11595
### 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 Get file list failed ### SeaTunnel Version 2.3.12 ### SeaTunnel Config ```conf seatunnel_101270_1076985.conf配置文件： env { "flink.restart-strategy"=none "flink.yarn.queue"=default "job.mode"=BATCH parallelism=1 "read_limit.bytes_per_second"=10485760 "read_limit.rows_per_second"=10000 } source { FtpFile { "connection_mode"="passive_local" "file_format_type"=binary host="192.168.63.199" password=123456 path="/pathimages/pdfbg/2023-03/" "plugin_output"="source_table1" port=21 user=ftpuser } } sink { S3File { "access_key"=admin bucket="s3a://pathimages" "data_save_mode"="DROP_DATA" "file_format_type"=binary "fs.s3a.aws.credentials.provider"="org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider" "fs.s3a.endpoint"="http://192.168.62.155:6945"; path="/pathimages/xx/pdfbg/2023-03/binary" "plugin_input"="source_table1" "secret_key"=xxxx } } ``` ### Running Command ```shell ${SEATUNNEL_HOME}/bin/start-seatunnel-flink-15-connector-v2.sh --config /data/test/1076985/seatunnel_101270_1076985.conf --deploy-mode run -Dtaskmanager.numberOfTaskSlots=2 -Djobmanager.memory.process.size=1g -Dtaskmanager.memory.process.size=2g --master yarn-per-job ``` ### Error Exception ```log org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery [] - Load Factory Plugin from /data/seatunnel/connectors 2026-07-28 11:54:40,678 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery [] - Load SeaTunnelSource Plugin from /data/seatunnel/connectors 2026-07-28 11:54:40,692 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery [] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='FtpFile'} at: [file:/data/seatunnel/connectors/connector-file-ftp-2.3.12.jar] 2026-07-28 11:54:40,692 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery [] - find connector jar and dependency for PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='FtpFile'}: [file:/data/seatunnel/connectors/connector-file-ftp-2.3.12.jar] 2026-07-28 11:54:40,730 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery [] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='FtpFile'} at: [file:/data/seatunnel/connectors/connector-file-ftp-2.3.12.jar] 2026-07-28 11:54:40,764 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery [] - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='FtpFile'} from path: [file:/data/seatunnel/connectors/connector-file-ftp-2.3.12.jar] use classloader: org.apache.flink.util.FlinkUserCodeClassLoaders$ParentFirstClassLoader 2026-07-28 11:54:40,917 INFO org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem [] - Using passive mode for FTP connection 2026-07-28 11:54:40,917 INFO org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem [] - Successfully connected to FTP server 192.168.63.157:21 in PASSIVE_LOCAL [INFO] 2026-07-28 11:56:47.570 +0800 - process has exited. execute path:/tmp/dolphinscheduler/exec/process/hive/18000632157120/22346293491264_1/101212/1076576, processId:544476 ,exitStatusCode:1 ,processWaitForStatus:true ,processExitValue:1 [INFO] 2026-07-28 11:56:47.571 +0800 - Send task execute result to master, the current task status: TaskExecutionStatus{code=6, desc='failure'} [INFO] 2026-07-28 11:56:47.571 +0800 - Remove the current task execute context from worker cache [INFO] 2026-07-28 11:56:47.571 +0800 - The current execute mode isn't develop mode, will clear the task execute file: /tmp/dolphinscheduler/exec/process/hive/18000632157120/22346293491264_1/101212/1076576 [INFO] 2026-07-28 11:56:47.571 +0800 - Success clear the task execute file: /tmp/dolphinscheduler/exec/process/hive/18000632157120/22346293491264_1/101212/1076576 [INFO] 2026-07-28 11:56:47.581 +0800 - -> 2026-07-28 11:56:47,512 ERROR org.apache.seatunnel.core.starter.SeaTunnel [] - =============================================================================== 2026-07-28 11:56:47,512 ERROR org.apache.seatunnel.core.starter.SeaTunnel [] - Fatal Error, 2026-07-28 11:56:47,512 ERROR org.apache.seatunnel.core.starter.SeaTunnel [] - Please submit bug report in https://github.com/apache/seatunnel/issues 2026-07-28 11:56:47,512 ERROR org.apache.seatunnel.core.starter.SeaTunnel [] - Reason:ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'FtpFile'. 2026-07-28 11:56:47,514 ERROR org.apache.seatunnel.core.starter.SeaTunnel [] - Exception StackTrace:org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'FtpFile'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86) at org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.initializePlugins(SourceExecuteProcessor.java:124) at org.apache.seatunnel.core.starter.flink.execution.FlinkAbstractPluginExecuteProcessor.<init>(FlinkAbstractPluginExecuteProcessor.java:85) at org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.<init>(SourceExecuteProcessor.java:68) at org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.<init>(FlinkExecution.java:120) at org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:71) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.flink.SeaTunnelFlink.main(SeaTunnelFlink.java:34) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:843) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:240) at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1087) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1165) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1899) at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1165) Caused by: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-03], ErrorDescription:[Get file list failed] - Get file list from this path [/pathimages/pdfbg/2023-03/] failed at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.parseFilePaths(BaseFileSourceConfig.java:76) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.<init>(BaseFileSourceConfig.java:64) at org.apache.seatunnel.connectors.seatunnel.file.ftp.config.FTPFileSourceConfig.<init>(FTPFileSourceConfig.java:43) at org.apache.seatunnel.connectors.seatunnel.file.ftp.config.MultipleTableFTPFileSourceConfig.getBaseSourceConfig(MultipleTableFTPFileSourceConfig.java:32) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseMultipleTableFileSourceConfig.parseFromFileSourceConfig(BaseMultipleTableFileSourceConfig.java:56) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseMultipleTableFileSourceConfig.<init>(BaseMultipleTableFileSourceConfig.java:41) at org.apache.seatunnel.connectors.seatunnel.file.ftp.config.MultipleTableFTPFileSourceConfig.<init>(MultipleTableFTPFileSourceConfig.java:27) at org.apache.seatunnel.connectors.seatunnel.file.ftp.source.FtpFileSource.<init>(FtpFileSource.java:27) at org.apache.seatunnel.connectors.seatunnel.file.ftp.source.FtpFileSourceFactory.lambda$createSource$0(FtpFileSourceFactory.java:48) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:180) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:136) ... 24 more Caused by: java.net.SocketException: Connection reset at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:115) at java.net.SocketOutputStream.write(SocketOutputStream.java:155) at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:221) at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:291) at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:295) at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:141) at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:229) at java.io.BufferedWriter.flush(BufferedWriter.java:254) at org.apache.commons.net.ftp.FTP.send(FTP.java:1109) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:1218) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:1148) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:1131) at org.apache.commons.net.ftp.FTP.quit(FTP.java:1018) at org.apache.commons.net.ftp.FTPClient.logout(FTPClient.java:2458) at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.disconnect(SeaTunnelFTPFileSystem.java:251) at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.listStatus(SeaTunnelFTPFileSystem.java:476) at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.lambda$listStatus$8(HadoopFileSystemProxy.java:183) at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.execute(HadoopFileSystemProxy.java:327) at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.listStatus(HadoopFileSystemProxy.java:183) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.AbstractReadStrategy.getFileNamesByPath(AbstractReadStrategy.java:116) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.parseFilePaths(BaseFileSourceConfig.java:73) ... 34 more 2026-07-28 11:56:47,515 ERROR org.apache.seatunnel.core.starter.SeaTunnel [] - =============================================================================== ------------------------------------------------------------ The program finished with the following exception: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'FtpFile'. at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98) at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:843) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:240) at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1087) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1165) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1899) at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1165) Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'FtpFile'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86) at org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.initializePlugins(SourceExecuteProcessor.java:124) at org.apache.seatunnel.core.starter.flink.execution.FlinkAbstractPluginExecuteProcessor.<init>(FlinkAbstractPluginExecuteProcessor.java:85) at org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.<init>(SourceExecuteProcessor.java:68) at org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.<init>(FlinkExecution.java:120) at org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:71) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.flink.SeaTunnelFlink.main(SeaTunnelFlink.java:34) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ... 11 more Caused by: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-03], ErrorDescription:[Get file list failed] - Get file list from this path [/pathimages/pdfbg/2023-03/] failed at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.parseFilePaths(BaseFileSourceConfig.java:76) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.<init>(BaseFileSourceConfig.java:64) at org.apache.seatunnel.connectors.seatunnel.file.ftp.config.FTPFileSourceConfig.<init>(FTPFileSourceConfig.java:43) at org.apache.seatunnel.connectors.seatunnel.file.ftp.config.MultipleTableFTPFileSourceConfig.getBaseSourceConfig(MultipleTableFTPFileSourceConfig.java:32) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseMultipleTableFileSourceConfig.parseFromFileSourceConfig(BaseMultipleTableFileSourceConfig.java:56) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseMultipleTableFileSourceConfig.<init>(BaseMultipleTableFileSourceConfig.java:41) at org.apache.seatunnel.connectors.seatunnel.file.ftp.config.MultipleTableFTPFileSourceConfig.<init>(MultipleTableFTPFileSourceConfig.java:27) at org.apache.seatunnel.connectors.seatunnel.file.ftp.source.FtpFileSource.<init>(FtpFileSource.java:27) at org.apache.seatunnel.connectors.seatunnel.file.ftp.source.FtpFileSourceFactory.lambda$createSource$0(FtpFileSourceFactory.java:48) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:180) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:136) ... 24 more Caused by: java.net.SocketException: Connection reset at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:115) at java.net.SocketOutputStream.write(SocketOutputStream.java:155) at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:221) at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:291) at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:295) at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:141) at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:229) at java.io.BufferedWriter.flush(BufferedWriter.java:254) at org.apache.commons.net.ftp.FTP.send(FTP.java:1109) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:1218) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:1148) at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:1131) at org.apache.commons.net.ftp.FTP.quit(FTP.java:1018) at org.apache.commons.net.ftp.FTPClient.logout(FTPClient.java:2458) at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.disconnect(SeaTunnelFTPFileSystem.java:251) at org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.listStatus(SeaTunnelFTPFileSystem.java:476) at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.lambda$listStatus$8(HadoopFileSystemProxy.java:183) at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.execute(HadoopFileSystemProxy.java:327) at org.apache.seatunnel.connectors.seatunnel.file.hadoop.HadoopFileSystemProxy.listStatus(HadoopFileSystemProxy.java:183) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.AbstractReadStrategy.getFileNamesByPath(AbstractReadStrategy.java:116) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.parseFilePaths(BaseFileSourceConfig.java:73) ... 34 more [INFO] 2026-07-28 11:56:47.582 +0800 - FINALIZE_SESSION ``` ### Zeta or Flink or Spark Version flink 1.16 ### Java or Scala Version jdk 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
