yanhan-chan commented on issue #5958: URL: https://github.com/apache/seatunnel/issues/5958#issuecomment-1874890836
<img width="899" alt="image" src="https://github.com/apache/seatunnel/assets/112475120/af95b1f8-c0ab-46c4-97ff-7cbd0afb9981";> @Carl-Zhou-CN Hi, I have added it in the pom.xml, however this time i got this error: I have also added this as i saw a similar error on the other post: <img width="303" alt="image" src="https://github.com/apache/seatunnel/assets/112475120/430f6a80-f1aa-462f-ab97-9e395bddc0d7";> org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample 2024-01-03 12:39:20,203 INFO org.apache.seatunnel.core.starter.utils.ConfigBuilder - Loading config file from path: /home/yanhan/SeaTunnel-Dev/seatunnel-dev/seatunnel-examples/seatunnel-flink-connector-v2-example/target/classes/examples/local_csv_to_console.conf 2024-01-03 12:39:20,242 INFO org.apache.seatunnel.core.starter.utils.ConfigShadeUtils - Load config shade spi: [base64] 2024-01-03 12:39:20,569 INFO org.apache.seatunnel.core.starter.utils.ConfigBuilder - Parsed config file: { "env" : { "execution.parallelism" : 2, "job.mode" : "BATCH", "checkpoint.interval" : 10000 }, "source" : [ { "schema" : { "fields" : { "name" : "string", "age" : "int" } }, "path" : "src/main/resources/sample_local_resources/local_csv.csv", "file_format_type" : "csv", "plugin_name" : "LocalFile" } ], "sink" : [ { "plugin_name" : "Console" } ] } 2024-01-03 12:39:20,619 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSource Plugin from /home/yanhan/SeaTunnel-Dev/seatunnel-dev/seatunnel-common/connectors 2024-01-03 12:39:20,620 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load Factory Plugin from /home/yanhan/SeaTunnel-Dev/seatunnel-dev/seatunnel-common/connectors 2024-01-03 12:39:20,645 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='LocalFile'} from classpath Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/fs/FSDataInputStream at org.apache.seatunnel.connectors.seatunnel.file.config.FileFormat$1.getReadStrategy(FileFormat.java:46) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.ReadStrategyFactory.of(ReadStrategyFactory.java:45) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.ReadStrategyFactory.of(ReadStrategyFactory.java:36) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseFileSourceConfig.<init>(BaseFileSourceConfig.java:63) at org.apache.seatunnel.connectors.seatunnel.file.local.source.config.LocalFileSourceConfig.<init>(LocalFileSourceConfig.java:44) at org.apache.seatunnel.connectors.seatunnel.file.local.source.config.MultipleTableLocalFileSourceConfig.getBaseSourceConfig(MultipleTableLocalFileSourceConfig.java:32) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseMultipleTableFileSourceConfig.parseFromFileSourceConfig(BaseMultipleTableFileSourceConfig.java:54) at org.apache.seatunnel.connectors.seatunnel.file.config.BaseMultipleTableFileSourceConfig.<init>(BaseMultipleTableFileSourceConfig.java:39) at org.apache.seatunnel.connectors.seatunnel.file.local.source.config.MultipleTableLocalFileSourceConfig.<init>(MultipleTableLocalFileSourceConfig.java:27) at org.apache.seatunnel.connectors.seatunnel.file.local.source.LocalFileSource.<init>(LocalFileSource.java:28) at org.apache.seatunnel.connectors.seatunnel.file.local.source.LocalFileSourceFactory.lambda$createSource$0(LocalFileSourceFactory.java:47) at org.apache.seatunnel.core.starter.execution.PluginUtil.createSource(PluginUtil.java:85) 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:91) 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) Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.fs.FSDataInputStream at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641) at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:526) ... 19 more Process finished with exit code 1 <img width="865" alt="image" src="https://github.com/apache/seatunnel/assets/112475120/56ab5537-3f7d-47d3-9134-744d90ad99a6";> -- 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 For queries about this service, please contact Infrastructure at: us...@infra.apache.org
