请教一下Flink，上面这个parse是自定义udf，为什么会调用3次udtf呢？

Flink的Table API和SQL提供了多种自定义函数的接口，以抽象类的形式定义。目前UDF主要有以下几类：

1. 标量函数（Scalar Functions）：将输入的标量值转换成一个新的标量值。
2. 表函数（Table Functions）：将输入的表转换成一个新的表。
3. 用户自定义函数（User-defined Functions）：用户自定义的函数。

在Flink中，对于JSON数据的操作，通常使用的是UDTF（用户自定义函数）来处理。在你的例子中，table1只有一行数据，外层select了3次json_data，为什么会调用3次udtf呢？可能的原因是，在Flink中，对于JSON数据的操作，通常需要使用UDTF进行多次处理，才能得到所需的结果。例如，可以使用UDTF来解析JSON数据，然后对解析出的数据进行进一步的处理，最后将处理后的数据返回给用户。在你的例子中，可能需要使用UDTF来解析JSON数据，然后再对解析出的数据进行3次处理，最后将处理后的数据返回给用户。

Flink的UDTF（User Defined Table-Generating Function）是一个可以生成多张表的函数。当你在SELECT语句中使用UDTF时，Flink会为每个生成的表调用一次UDTF。

在你的情况下，你在外层SELECT语句中选择了3次JSON_DATA，这意味着Flink会为每个选择的JSON_DATA生成一张表，所以它会调用UDTF三次。

这与你是否有数据无关，只要你在SELECT语句中选择了一个字段，Flink就会为每个选择的字段生成一张表，并调用UDTF。

试试指定checkpoint的路径，此回答整理自钉群“【③群】Apache Flink China社区”