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

请教一下Flink1.16版本源码本地是怎么调试的

请教一下Flink1.16版本源码本地是怎么调试的

展开
收起
JWRRR 2023-04-03 14:54:26 439 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    在本地调试Flink 1.16版本的源码,可以按照以下步骤进行:

    1、下载Flink源码并导入您使用的IDE(如IntelliJ IDEA)中。

    2、在IDE中打开Flink源码根目录中的pom.xml文件,加载所有的依赖库。

    3、在IDE中创建一个新的“Run Configuration”,并选择Flink中任何一个可执行程序(如org.apache.flink.streaming.examples.wordcount.WordCount)作为入口类。

    4、在“Run Configuration”中设置程序运行时所需的参数,例如输入输出路径、Kafka地址、checkpoint路径等等。

    5、点击IDE中的“Debug”按钮启动程序,并在调试器中设置断点进行调试。

    6、可以在IDE中使用调试器来单步执行代码,并查看每个变量的值,以帮助了解Flink的运行过程。

    7、如果需要查看Flink的日志信息,可以在conf/log4j.properties文件中设置日志级别和输出路径。

    2023-04-14 16:00:44
    赞同 展开评论 打赏

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

相关产品

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

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