SaphanaTest test = new SaphanaTest();}错误堆栈跟踪:
线程"main“org.apache.spark.SparkException:任务中的异常不能在、org.apache.spark.util.ClosureCleaner$.ensureSerializable(ClosureCleaner.scala:315)、org.apache.spark.util.ClosureCleanerorg.apache.spark.SparkConte
我试图通过foreachpartition将结果添加到mysql中,但得到错误org.apache.spark.SparkException: Task not serializable java。20 12:37:58 INFO SparkContext: Created broadcast 0 from textFile at Insert.java:41
org.apache.spark.SparkException