Вызывается: java .lang.ClassNotFoundException: org / apache / spark / sql / execute / WholeStageCodegenExec $$ anonfun $ 10 $$ anon $ 1 в java .lang.Class.forName0 (собственный метод) в java .lang.Class.forName (Class. java: 348) в орг. apache .spark.util.InnerClosureFinder $$ anon $ 4.visitMethodInsn (ClosureCleaner. scala: 484) в орг. apache. xbean.asm5.ClassReader.a (Неизвестный источник) в org. apache .xbean.asm5.ClassReader.b (Неизвестный источник) в org. apache .xbean.asm5.ClassReader.accept (Неизвестный источник) в org. apache .xbean.asm5.ClassReader.accept (Неизвестный источник) в org. apache .spark.util.ClosureCleaner $ .getInnerClosureClasses (ClosureCleaner. scala: 87) в org. apache .spark.util. ClosureCleaner $ .org $ apache $ spark $ util $ ClosureCleaner $$ clean (ClosureCleaner. scala: 224) в орг. apache .spark.util.ClosureCleaner $ .clean (ClosureCleaner. scala: 159) в орг. . apache .spark.SparkContext.clean (SparkContext. scala: 2292) в орг. apache .spark.rdd.RDD $$ anonfun $ mapPartitionsWithIndex $ 1.применить (СДР. scala: 844) в орг. . apache .spark.rdd.RDD $$ ано nfun $ mapPartitionsWithIndex $ 1.apply (СДР. scala: 843) в орг. apache .spark.rdd.RDDOperationScope $ .withScope (RDDOperationScope. scala: 151) в орг. apache .spark.rdd. RDDOperationScope $ .withScope (RDDOperationScope. scala: 112) в орг. apache .spark.rdd.RDD.withScope (RDD. scala: 363) в орг. apache .spark.rdd.RDD.mapPartitionsWithIndex (СДР. scala: 843) в орг. apache .spark. sql .execution.WholeStageCodegenExe c .doExecute (WholeStageCodegenExe c. scala: 608) в орг. apache .spark . sql .execution.SparkPlan $$ anonfun $ execute $ 1.apply (SparkPlan. scala: 131) в org. apache .spark. sql .execution.SparkPlan $$ anonfun $ execute $ 1.apply ( SparkPlan. scala: 127) в орг. apache .spark. sql .execution.SparkPlan $$ anonfun $ executeQuery $ 1.apply (SparkPlan. scala: 155) в орг. apache .spark. rdd.RDDOperationScope $ .withScope (RDDOperationScope. scala: 151) в орг. apache .spark. sql .execution.SparkPlan.executeQuery (SparkPlan. scala: 152) в орг. apache .spark . sql .execution.SparkPlan.execute (SparkPlan. scala: 127) в орг. apache .spark . sql .execution.SparkPlan.getByteArrayRdd (SparkPlan. scala: 247) в организации. apache .spark. sql .execution.SparkPlan.executeCollectIterator (SparkPlan. scala: 304) в организации. apache .spark. sql .execution.exchange.BroadcastExchangeExec $$ anonfun $ ratioFuture $ 1 $$ anonfun $ apply $ 1.apply (BroadcastExchangeExe c. scala: 76) в орг. apache .spark. sql .execution.exchange.BroadcastExchangeExec $$ anonfun $ отношениеFuture $ 1 $$ anonfun $ apply $ 1.apply (BroadcastExchangeExe c. scala: 73) в орг. apache .spark. sql .execution.SQLExecution $ .withExecutionId (SQLExecution. scala: 97) в орг. apache .spark. sql .execution.exchange.BroadcastExchangeExec $$ anonfun $ отношениеFuture $ 1.apply (BroadcastExchangeExe c. scala: 72) в орг. apache .spark. sql .execution.exchange.BroadcastExchangeExec $$ anonfun $ RelationsFuture $ 1.apply (BroadcastExchangeExe c. scala: 72) в scala .concurrent.impl.Future $ PromiseCompletingRunnable .liftedTree1 $ 1 (Будущее. scala: 24) в scala .concurrent.impl.Future $ PromiseCompletingRunnable.run (Будущее. * 108 2 *: 24) ... еще 3