更新时间:2024-08-03 GMT+08:00

调测Flink SpringBoot样例程序

该章节内容适用于MRS 3.3.0及之后版本。

SpringBoot样例工程的命令行形式运行

  1. 在IDEA界面使用Maven执行install。

    当输出“BUILD SUCCESS”,表示编译成功,如下图所示。编译成功后将会在样例工程的target下生成含有“flink-dws-sink-example-1.0.0-SNAPSHOT”字段的Jar包。

  2. 在Linux上进入客户端安装目录,如“/opt/client/Flink/flink/conf”作为作为运行目录,将1中生成的“target”目录下包名中含有“flink-dws-sink-example-1.0.0-SNAPSHOT”字段的Jar包放进该路径。
  3. 执行以下命令创建yarn-session。

    yarn-session.sh -t ssl/ -nm "session-spring11" -d

  4. 执行以下命令启动SpringBoot服务。

    • 执行GaussDB(DWS)样例

      flink run flink-dws-sink-example.jar