udf测试  flinkc程序测试 参考flink1.20文档 文档很多地方跑不通甚至没有import对应的包,这里全都标注了. 且代码做了修改来确保了成功执行.

Test Dependencies | Apache Flink

Testing | Apache Flink

maven

官网写的 flink-test-util flink-table-test-util 外加 scalatest和scalamock

<dependency>
            <groupId>org.scalatest</groupId>
            <artifactId>scalatest_${scala.version}</artifactId>
            <version>${scala.te