mesutmutluitu commented on issue #8493:
URL: https://github.com/apache/seatunnel/issues/8493#issuecomment-2663037138
same problem here
`POST]{uri='/hazelcast/rest/maps/submit-job'}AbstractTextCommand[HTTP_POST]{requestId=2}
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:119)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:68)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:404)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:236)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.RestJobExecutionEnvironment.getLogicalDag(RestJobExecutionEnvironment.java:86)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.RestJobExecutionEnvironment.build(RestJobExecutionEnvironment.java:122)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.service.BaseService.submitJobInternal(BaseService.java:505)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.service.JobInfoService.submitJob(JobInfoService.java:173)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handleSubmitJob(RestHttpPostCommandProcessor.java:114)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:82)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:44)
~[seatunnel-starter.jar:2.3.9]
at
com.hazelcast.internal.ascii.TextCommandServiceImpl$CommandExecutor.run(TextCommandServiceImpl.java:402)
~[seatunnel-starter.jar:2.3.9]
at
com.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217)
~[seatunnel-starter.jar:2.3.9]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_342]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_342]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
at
com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)
~[seatunnel-starter.jar:2.3.9]
at
com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)
~[seatunnel-starter.jar:2.3.9]
Caused by:
org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException:
ErrorCode:[FILE-03], ErrorDescription:[Get file list failed] - Get file list
from this path [/dir2] 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:131)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:91)
~[seatunnel-starter.jar:2.3.9]
... 17 more
Caused by: java.io.FileNotFoundException: File /dir2 does not exist.
at
org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.getFileStatus(SeaTunnelFTPFileSystem.java:492)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.listStatus(SeaTunnelFTPFileSystem.java:439)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.file.ftp.system.SeaTunnelFTPFileSystem.listStatus(SeaTunnelFTPFileSystem.java:424)
~[?:?]
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:110)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.parseFilePaths(BaseFileSourceConfig.java:73)
~[?:?]
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:131)
~[seatunnel-starter.jar:2.3.9]
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:91)
~[seatunnel-starter.jar:2.3.9]
... 17 more`
--
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]
