Я выполнял следующий SQL запрос:
select count(*) from A where
A.y <= double((select y from B) + 0.5) and
A.y >= double((select y from B) - 0.5) and
A.x <= double((select x from B) + 0.5) and
A.x >= double((select x from B) - 0.5)
Spark-stream дал мне эту ошибку:
org.apache.spark.sql.AnalysisException: Multiple streaming aggregations are not supported with streaming DataFrames/Datasets
Я немного новичок в Spark и не смог найти много ресурсов, чтобы помочь мне решить эту проблему. Может ли кто-нибудь предоставить мне решение или план действий, как это исправить и почему появилось это сообщение об ошибке.
Спасибо