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 では、null チェックは group by で使用すると機能せずLENGTH()
、値の呼び出しと null チェックが正しく機能することを知っています。
上記のクエリを実行すると、次のエラーが表示されます。
SQL Error: java.lang.IllegalArgumentException: Unrecognized type name: null\"
問題は何ですか?