当前位置: 首页 > article >正文

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找到了原因。


http://www.kler.cn/a/517786.html

相关文章:

  • HashSet经典面试题
  • Git知识分享
  • 5. 马科维茨资产组合模型+政策意图AI金融智能体(Qwen-Max)增强方案(理论+Python实战)
  • 企业微信第三方应用开发006_开发配置_配置网络穿透_配置数据回调_指令回调_连接后台---企业微信开发009
  • ffmpeg的AVOption用法
  • YOLOv5模型版本详解:n/s/m/l的区别与选型指南
  • GEE | ERA5不同土壤层水分和温度变化
  • 【gopher的java学习笔记】一文讲懂controller,service,mapper,entity是什么
  • ChatGPT大模型极简应用开发-CH5-使用 LangChain 框架和插件增强 LLM 的功能
  • pip国内源汇总
  • mysql-06.JDBC
  • 财税资金数据管理一体化大屏 | 智慧金融合集
  • YOLOv11实战天气图像识别
  • openstack单机安装
  • 激光线扫相机无2D图像的标定方案
  • Level2逐笔成交逐笔委托毫秒记录:今日分享优质股票数据20250124
  • 朴素贝叶斯(Naive Bayes)详解
  • 寒假刷题Day13
  • UDP協議與代理IP介紹
  • 携程旅行 登录分析