我在这里做错什么了?线程"main“中的异常:在org.apache.spark.util.ClosureCleaner$.ensureSerializable(ClosureCleaner.scala:315) at org.apache.spark.util.ClosureCleanerorg.apache上不可序列化的任务.spark.rdd.RDD$$anonfun$foreach
我注意到在DataFrame上使用了一个窗口函数之后,如果我用一个函数调用map(),那么Spark会返回一个“任务不可序列化”的异常--这是我的代码:
val hc:org.apache.spark.sql.hive.HiveContext$.ensureSerializable(ClosureCleaner.scala:304) at org.apache.spark.util.ClosureC