开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

我刚开始使用flink jar开发,下载了官方文档快速入门t的测试案例,不知道为什么会报错,咋解决?

我刚开始使用flink jar开发,下载了官方文档快速入门的wordcount的测试案例,不知道为什么会报找不到main方法的错误。
2f86df6880999093f00622294c9604bf.png
b00431daf9182bc499927fb0740ea57b.png

展开
收起
嘟嘟嘟嘟嘟嘟 2024-01-17 09:31:55 65 0
2 条回答
写回答
取消 提交回答
  • 7ae3f318f7278ae64cf1dd3c8505f445.png
    原因:Java虚拟机在编译时能找到合适的类,而在运行时不能找到合适的类导致的错误。这个错误发生只在运行时需要加载对应的类不成功,而不是编译时发生。包冲突问题官网文档有描述,您可以参考下
    f72a0c756b54a1f8241cf0408673f84c.png
    https://help.aliyun.com/zh/flink/user-guide/develop-a-jar-draft?spm=a2c4g.11186623.0.i23
    社区可参考的文章:
    https://blog.csdn.net/jamesjxin/article/details/46606307?spm=ata.21736010.0.0.67727536K2FTte
    此回答整理自钉群“实时计算Flink产品交流群”

    2024-02-03 09:12:55
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    这个问题可能是因为你没有正确地编译和打包Flink程序。请按照以下步骤操作:

    1. 确保你已经安装了Java Development Kit (JDK) 和 Apache Maven。

    2. 使用Maven命令行工具,进入到包含flink-quickstart-java目录的父目录。例如:

    cd path/to/your/flink-quickstart-java/parent/directory
    
    1. 在命令行中运行以下命令以编译和打包Flink程序:
    mvn clean package
    
    1. 编译成功后,你会在target目录下看到一个名为flink-quickstart-java-0.1_2.11-SNAPSHOT.jar的文件。这个文件就是你需要执行的Flink程序。

    2. 使用以下命令运行Flink程序:

    java -cp target/flink-quickstart-java-0.1_2.11-SNAPSHOT.jar org.apache.flink.quickstart.WordCount <input> <output>
    

    其中,<input>是输入数据的路径,<output>是输出结果的路径。例如:

    java -cp target/flink-quickstart-java-0.1_2.11-SNAPSHOT.jar org.apache.flink.quickstart.WordCount hdfs://localhost:9000/user/root/input hdfs://localhost:9000/user/root/output
    

    如果你仍然遇到找不到main方法的错误,请检查你的项目是否正确地使用了Flink提供的依赖库。你可以在pom.xml文件中查看这些依赖库的配置。

    2024-01-17 14:07:47
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载