raise_error：抛出异常

速查结论

raise_error(expr) 是 Spark SQL 中用于手动抛出带有自定义错误信息的异常的函数。

语法

raise_error(expr)

参数说明

参数	说明
expr	字符串表达式，作为异常的错误信息内容

示例

> SELECT raise_error('custom error message');
 java.lang.RuntimeException
 custom error message

常见报错与避坑指南

• 查询中断：raise_error 会立即抛出 java.lang.RuntimeException 并中断整个查询。不要在正常数据流中使用，仅在需要主动终止查询时调用。
• 典型场景：常用于 CASE WHEN 或 assert_true 配合使用，当数据不满足业务规则时主动报错并给出有意义的错误提示。
• 参数必须为字符串：expr 参数必须是 STRING 类型。如需拼接错误信息，可使用 concat() 函数构造动态消息。

Since: 3.1.0

📱关注公众号

「数据仓库技术」文章同步更新，不错过每一篇干货

💬加群交流

备注「数据仓库技术」加入社群，每日一道大厂SQL真题