yanhan-chan commented on issue #5958:
URL: https://github.com/apache/seatunnel/issues/5958#issuecomment-1859505371
Hi, does this example only runs for FakeSource and Console as sink, I was
trying to use the LocalFile connector as sink, but it is not working, below is
the code for the fake_to_console.conf file, a screenshot of the directories and
lastly the console output when i run SeaTunnelApiExample.java file
`
env {
job.mode = "BATCH"
execution.parallelism = 2
}
source {
LocalFile {
path = "/local_csv.csv"
file_format_type = "csv"
}
}
transform {
}
sink {
Console {
}
}
`
Directory:
<img width="304" alt="image"
src="https://github.com/apache/seatunnel/assets/112475120/f368140c-e6a5-4b3d-9407-ae983ac36ac9";>
Console Output:
2023-12-18 11:43:47,590 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
===============================================================================
2023-12-18 11:43:47,590 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Fatal Error,
2023-12-18 11:43:47,590 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Please submit bug report in https://github.com/apache/seatunnel/issues
2023-12-18 11:43:47,590 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Reason:Plugin PluginIdentifier{engineType='seatunnel', pluginType='source',
pluginName='LocalFile'} not found.
2023-12-18 11:43:47,592 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Exception StackTrace:java.lang.RuntimeException: Plugin
PluginIdentifier{engineType='seatunnel', pluginType='source',
pluginName='LocalFile'} not found.
at
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:231)
at
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:171)
at
org.apache.seatunnel.core.starter.execution.PluginUtil.fallbackCreate(PluginUtil.java:128)
at
org.apache.seatunnel.core.starter.execution.PluginUtil.createSource(PluginUtil.java:77)
at
org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.initializePlugins(SourceExecuteProcessor.java:118)
at
org.apache.seatunnel.core.starter.flink.execution.FlinkAbstractPluginExecuteProcessor.<init>(FlinkAbstractPluginExecuteProcessor.java:76)
at
org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.<init>(SourceExecuteProcessor.java:61)
at
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.<init>(FlinkExecution.java:86)
at
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:59)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main(SeaTunnelApiExample.java:39)
2023-12-18 11:43:47,592 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
===============================================================================
Exception in thread "main" java.lang.RuntimeException: Plugin
PluginIdentifier{engineType='seatunnel', pluginType='source',
pluginName='LocalFile'} not found.
at
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:231)
at
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:171)
at
org.apache.seatunnel.core.starter.execution.PluginUtil.fallbackCreate(PluginUtil.java:128)
at
org.apache.seatunnel.core.starter.execution.PluginUtil.createSource(PluginUtil.java:77)
at
org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.initializePlugins(SourceExecuteProcessor.java:118)
at
org.apache.seatunnel.core.starter.flink.execution.FlinkAbstractPluginExecuteProcessor.<init>(FlinkAbstractPluginExecuteProcessor.java:76)
at
org.apache.seatunnel.core.starter.flink.execution.SourceExecuteProcessor.<init>(SourceExecuteProcessor.java:61)
at
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.<init>(FlinkExecution.java:86)
at
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:59)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main(SeaTunnelApiExample.java:39)
--
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]
