FlinkSql使用中rank/dense_rank函数报错空指针

问题描述

在flink1.16(甚至以前的版本)中，使用rank()或者dense_rank()进行排序时，某些场景会导致报错空指针NPE(NullPointerError)

报错内容如下

该报错没有行号/错误位置，无法排查

现状

目前已经确认为bug，根据github上的PR日志，目前在1.18及以上的版本中已经修复，现阶段用老版本的Coder们只能用row_number来代替下。

在新版本中，通过添加为空情况的判断，来避免掉了这个报错。

BUG问题表现及修复的方式具体看[FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()… by chenzihao5 · Pull Request #19797 · apache/flink · GitHub

总结

个人在排查过程中经历了极大的困难，主要原因是国内搜索引擎和gpt并未给出相关的结论，最后一页页翻apache issue找到了原因。

文章来源于互联网:FlinkSql使用中rank/dense_rank函数报错空指针

相关推荐: 【AIGC系列】frequency_penalty如何通过控制参数提升文本生成的多样性与创造性

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学习,不断总结,共同进步,活到老学到老 导航 檀越剑指大厂系列:全面总结…