udtf collect方法 报NEP
Hi all, 我在使用udtf 调用collect方法的时候出现空指针异常，显示collector对象为null,第一次调用正常，第二次调用数据被标记了 “INSERT”是什么意思？ https://imgchr.com/i/D0HuCj https://imgchr.com/i/D0Hm5Q udtf代码： https://imgchr.com/i/D0HeUg
*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
+I 表示是一条 insert 的数据，其它类型的可以查看： https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/types/RowKind.java
其中 NPE 问题，你是用哪个版本的呢？ 方便复制下 sql 和 udtf 吗，我看下能不能复现。 PS：“第一次调用正常” 是指？ *来自志愿者整理的flink邮件归档
2021-12-06 14:09:37赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
