有什么辦法可以繞過這個報錯嗎?
sql如下:
SELECT COUNT(*) total,t.col1,t.col2,t.col3,t.col4
CASE WHEN col3='abc' THEN (SELECT MAX(col2) FROM xxx_log f WHERE col4='xxx11' AND col1=t.col1
AND col2=t.col2 ) ELSE t.col2 END newCol2
FROM xxx_log t
報錯資訊:
xception in thread "main" org.apache.spark.sql.AnalysisException: Multiple streaming aggregations are not supported with streaming DataFrames/Datasets;;
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/243704.html
標籤:Spark