标签： Flink udf的小问题：无参数的udf函数会被优化成常量表达式

这两天有一个使用flink sql的实时流项目，需要在每个结果中标记当前时间。因为flink没有获取当前时间的函数，于是我自己定义了一个udf： import org.apache.flink.tab … Continue reading Flink udf的小问题：无参数的udf函数会被优化成常量表达式