Hi Elior,
Could you show the query that led to the exception?
Pozdrawiam,
Jacek Laskowski
https://about.me/JacekLaskowski
Mastering Spark SQL https://bit.ly/mastering-spark-sql
Spark Structured Streaming https://bit.ly/spark-structured-streaming
Mastering Kafka Streams https://bit.ly/masteri
Exception in thread "main" org.apache.spark.sql.AnalysisException:
collect_set(named_struct(value, country#123 AS value#346, count,
(cast(count(country#123) windowspecdefinit ion(campaign_id#104, app_id#93,
country#123, ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING) as
double) /
