問題描述

spark sql中運行報錯

SQL：

SELECT his.name, his.oid FROM his_data_zadd AS his WHERE his.value=(SELECT MAX(temp_t.value) FROM his_data_zadd AS temp_t)

報錯信息：

py4j.protocol.Py4JJavaError: An error occurred while calling o32.sql.: java.lang.RuntimeException: [1.76] failure: ``)’’ expected but identifier MAX foundSELECT his.name, his.oid FROM his_data_zadd AS his WHERE his.value=(SELECT MAX(temp_t.value) FROM his_data_zadd AS temp_t)

是spark sql的語法解析器不支持這種寫法？還是我的sql語句原本就有問題？

問題解答

試下把SQLContext換成HiveContext