如何在 Intellij IDEA 中调试 flink 流作业答案

【问题标题】：How to debug flink streaming job in Intellij IDEA如何在 Intellij IDEA 中调试 flink 流作业
【发布时间】：2021-01-30 10:44:34
【问题描述】：

我想用一些逻辑（Scala）创建一个 Flink Job，并在文档中找到了几种启动 Flink 的方法。例如单机模式：

./bin/flink run ./examples/streaming/TopSpeedWindowing.jar

是否可以像使用主类的简单 Spark 作业一样从 Intellij Idea 启动和调试 Flink 作业？

  val spark = SparkSession.builder()
    .appName("Agg")
    .master("local")
    .getOrCreate()

  def streamCount() = {
    val lines: DataFrame = spark.readStream
...

  def main(args: Array[String]): Unit = {
    streamCount()
  }

使用 Flink 的方法有哪些？可能是一些用于单元测试或测试容器的特殊库。

【问题讨论】：

标签： scala unit-testing debugging intellij-idea apache-flink

【解决方案1】：

是的，你当然可以用 Flink 做到这一点。

您可以在https://github.com/apache/flink-training 中的 IDE 中轻松运行一些示例，包括 Java 和 Scala。这些练习附带的培训课程是 flink 文档的一部分：https://ci.apache.org/projects/flink/flink-docs-stable/learn-flink/。

【讨论】：