通过放置断点在 IntelliJ 中逐行调试 Flink Job
Debugging Flink Job Line by Line in IntelliJ by putting breakpoints
我是 Flink 世界的新手，想通过在 SensorTimeAssigner 和 AvegrageTemperatureWindow 函数中放置断点来逐行调试 Flink Job 类。
已关注这篇文章 Flink Setup
请帮我在 IntelliJ 中调试 FLink 作业 IDE。
io.github.streamingwithflink.chapter1.AverageSensorReadings.java
如文章所述，您需要将您的 Flink 项目导入 IntelliJ，然后您可以通过设置断点像任何其他应用程序一样调试它。
当你这样做时，你并没有使用单独的 Flink 集群，而是 Flink 的所有服务都运行与你的应用程序在同一个 JVM 中——所以 Flink 客户端、作业管理器和任务管理器在 IntelliJ 中 运行在一起。
有一件事你必须注意，这在最近的 IntelliJ 版本中变得有点难以找到，就是修改你的 运行 配置，以便你打开 包括具有“已提供”范围的依赖项。您会在 运行/编辑配置/修改选项/Java.
下找到它
我是 Flink 世界的新手，想通过在 SensorTimeAssigner 和 AvegrageTemperatureWindow 函数中放置断点来逐行调试 Flink Job 类。 已关注这篇文章 Flink Setup
请帮我在 IntelliJ 中调试 FLink 作业 IDE。
io.github.streamingwithflink.chapter1.AverageSensorReadings.java
如文章所述，您需要将您的 Flink 项目导入 IntelliJ，然后您可以通过设置断点像任何其他应用程序一样调试它。
当你这样做时，你并没有使用单独的 Flink 集群，而是 Flink 的所有服务都运行与你的应用程序在同一个 JVM 中——所以 Flink 客户端、作业管理器和任务管理器在 IntelliJ 中 运行在一起。
有一件事你必须注意，这在最近的 IntelliJ 版本中变得有点难以找到，就是修改你的 运行 配置，以便你打开 包括具有“已提供”范围的依赖项。您会在 运行/编辑配置/修改选项/Java.
下找到它