java - Spark 2.0 按空值分组

Question

致力于将一些查询从 Spark 1.5 迁移到 Spark 2.0

查询如下：

SELECT 
    users.age AS users_age,

  NULL

 AS users_running_total_on_null
FROM users

GROUP BY users.age
ORDER BY users_age 
LIMIT 1

首先，我知道在 Spark 中，空值检查在 group by 中使用时不起作用，并且调用LENGTH()值和空值检查可以正常工作。

运行上面的查询，我得到以下错误：

SQL Error: java.lang.IllegalArgumentException: Unrecognized type name: null\"

任何想法是什么问题？