Hi， +I 表示是一条 insert 的数据，其它类型的可以查看： https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/types/RowKind.java
其中 NPE 问题，你是用哪个版本的呢？ 方便复制下 sql 和 udtf 吗，我看下能不能复现。 PS：“第一次调用正常” 是指？ Best， Hailong 在 2020-11-26 17:25:03，"bulterman" <[email protected]> 写道： >Hi all, >我在使用udtf 调用collect方法的时候出现空指针异常，显示collector对象为null,第一次调用正常，第二次调用数据被标记了 >“INSERT”是什么意思？ >https://imgchr.com/i/D0HuCj >https://imgchr.com/i/D0Hm5Q >udtf代码： >https://imgchr.com/i/D0HeUg
