让Flink本地模式畅通WebUI，助力高效调试

2022-12-16 07:38:21

在本地模式下启动 Flink WebUI：调试和监视变得轻而易举

在开发 Flink 应用程序时，本地 WebUI 可以为我们提供巨大的便利。它允许我们轻松地调试和监视应用程序，深入了解其执行和资源利用率。让我们详细了解如何在本地模式下启动 Flink WebUI，并探索其好处。

首先，需要在 Flink 项目中添加必要的依赖项。对于 Java Flink 项目，添加以下依赖项：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-web</artifactId>
  <version>1.15.0</version>
</dependency>

对于 Scala Flink 项目，添加以下依赖项：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-scala-web_2.12</artifactId>
  <version>1.15.0</version>
</dependency>

添加依赖项后，需要配置本地 WebUI。可以在 Flink 配置文件中（例如 flink-conf.yaml）添加以下配置：

jobmanager.web.port: 8081

这将使本地 WebUI 在端口 8081 上运行。

现在，可以通过在 IntelliJ IDEA 中运行 Flink 应用程序来启动本地 WebUI。执行以下步骤：

您的 Flink 应用程序现在将在本地模式下运行，并且本地 WebUI 将在端口 8081 上运行。可以通过在浏览器中访问 http://localhost:8081 来访问本地 WebUI。

在本地模式下启动 Flink WebUI 有很多好处：

轻松调试和监视： WebUI 允许在开发过程中轻松地调试和监视应用程序。它提供有关执行计划、作业状态、指标和其他信息的实时数据。
深入了解应用程序运行情况： WebUI 有助于深入了解 Flink 应用程序的运行情况。它提供有关资源使用率、数据流和作业进度的信息，帮助优化应用程序性能并确保高效运行。