Spark структурированный поток: java.lang.NoClassDefFoundError для GroupStateTimeout [дубликат]

GroupStateTimeOut является частью модуля искрового катализатора . Посмотрите здесь: https://github.com/apache/spark/blob/master/sql/catalyst/src/main/java/org/apache/spark/sql/streaming/GroupStateTimeout.java [110 ]

Итак, вам нужно добавить искровой катализатор зависимость https://mvnrepository.com/artifact/org.apache.spark/spark-catalyst_2 .11 / 2.2.0 в вашем проекте. Надеюсь, это решит вашу проблему