为方便在Flink中写入数据到Hudi,需要导入Hudi集成Flink的编译jar包。

具体版本如下:

Hadoop:3.1.3

Flink:1.13.6

Scala:2.12

Hudi:0.12.0