Apache Arrow DataFusion 中复合字段访问与连接查询的回归问题分析
2025-06-14 12:46:30作者:尤峻淳Whitney
问题背景
在Apache Arrow DataFusion项目的最新版本46中,出现了一个关于复合字段访问和表连接查询的回归问题。这个问题主要影响那些需要连接两个具有相似列结构的表,并且在连接条件中使用复合字段访问(如结构体字段访问)的查询场景。
问题表现
在DataFusion CLI中,当用户尝试执行包含以下特征的查询时会出现问题:
- 创建包含结构体列的表
- 在这些表上执行连接操作
- 在连接条件中使用结构体字段访问表达式
具体表现为:
- 在版本45中正常工作的查询,在版本46中会抛出"Schema error: No field named..."的错误
- 简单查询(如单表过滤)和简单连接查询(不使用复合字段访问)仍然正常工作
技术分析
这个问题源于DataFusion项目中SQL解析器版本的更新(特别是PR #14255引入的变化)。新版本在解析包含表别名和复合字段访问的连接查询时,对字段引用的解析逻辑发生了变化。
在版本45中,系统能够正确识别如t.column1['r']这样的表达式,其中t是表别名,column1是列名,['r']是结构体字段访问。但在版本46中,解析器在处理这类表达式时出现了偏差,导致无法正确识别表别名。
影响范围
这个问题主要影响以下使用场景:
- Delta Lake表合并操作(特别是包含结构体的表)
- 任何需要在连接条件中使用复合字段访问的查询
- 使用表别名的复杂连接查询
解决方案
该问题已在主分支的最新提交中通过PR #15153得到修复。修复后的版本能够正确处理以下两种形式的查询:
- 使用表别名的连接查询:
select * from t tee join u you on tee.column1['r'] = you.column1['r'] - 不使用表别名的连接查询:
select * from t join u on t.column1['r'] = u.column1['r']
开发者建议
对于遇到此问题的开发者,建议:
- 升级到包含修复的主分支最新版本
- 在测试环境中验证所有涉及结构体字段访问的连接查询
- 如果暂时无法升级,可以考虑重写查询,避免在连接条件中使用复合字段访问
总结
这个回归问题提醒我们,在SQL解析器升级时需要特别注意边缘案例的测试覆盖。DataFusion团队通过快速响应和修复,确保了项目的稳定性和向后兼容性。对于使用DataFusion的项目,建议密切关注这类核心组件的更新,并在升级前进行充分的测试验证。
登录后查看全文
热门项目推荐
相关项目推荐
atomcodeClaude Code 的开源替代方案。连接任意大模型,编辑代码,运行命令,自动验证 — 全自动执行。用 Rust 构建,极致性能。 | An open-source alternative to Claude Code. Connect any LLM, edit code, run commands, and verify changes — autonomously. Built in Rust for speed. Get StartedRust0213
cann-learning-hubCANN 学习中心仓,支持在线互动运行、边学边练,提供教程、示例与优化方案,一站式助力昇腾开发者快速上手。Jupyter Notebook0138
uni-appA cross-platform framework using Vue.jsJavaScript08
GLM-5.2智谱开源 GLM-5.2,这是针对长文本任务的最新旗舰模型。相较于前代产品 GLM-5.1,它在长文本任务处理能力上实现了显著飞跃,并且首次在稳定的 100 万 token 上下文中提供这一能力。Jinja00
SwanLab⚡️SwanLab - an open-source, modern-design AI training tracking and visualization tool. Supports Cloud / Self-hosted use. Integrated with PyTorch / Transformers / LLaMA Factory / veRL/ Swift / Ultralytics / MMEngine / Keras etc.Python00
tiny-universe《大模型白盒子构建指南》:一个全手搓的Tiny-UniverseJupyter Notebook03
项目优选
收起
deepin linux kernel
C
32
16
openEuler内核是openEuler操作系统的核心,既是系统性能与稳定性的基石,也是连接处理器、设备与服务的桥梁。
C
469
465
暂无描述
Dockerfile
778
5.08 K
Ascend Extension for PyTorch
Python
757
968
本项目是CANN提供的transformer类大模型算子库,实现网络在NPU上加速计算。
C++
876
2.03 K
本项目是CANN提供的神经网络类计算算子库,实现网络在NPU上加速计算。
C++
697
1.4 K
昇腾LLM分布式训练框架
Python
185
231
JiuwenSwarm 是一款基于openJiuwen开发的智能AI Agent,它能够将大语言模型的强大能力,通过你日常使用的各类通讯应用,直接延伸至你的指尖。
Python
2.25 K
676
本项目是CANN提供的数学类基础计算算子库,实现网络在NPU上加速计算。
C++
1.1 K
1.14 K
本仓库是 Flutter SDK 与 Flutter Engine 的 OpenHarmony 适配版本,由 CPF-Flutter 团队维护。开发者可使用熟悉的 Flutter 技术栈开发 OpenHarmony 应用,3.35.7 及以后的适配版本可基于本仓库源码构建支持 OpenHarmony 的 Flutter Engine。
Dart
1.04 K
271