gpt4 book ai didi

java.io.NotSerializableException : org. apache.spark.SparkContext 序列化堆栈:- 对象不可序列化

转载 作者:搜寻专家 更新时间:2023-11-01 03:20:24 26 4
gpt4 key购买 nike

错误可以在 spark-shell 中重现。基本上,我定义了一个带有生成 RDD 的方法的类,然后我在生成序列化错误的 RDD 上执行映射操作。

如果我没有方法,只有执行方法步骤的语句,那么一切正常。

代码在这里,可以在spark-shell中运行我定义了一个类,然后实例化了这个类。

首先是进口

import java.nio.file.{Files}
import java.io._
import org.apache.spark.SparkContext
import org.apache.spark.rdd.RDD
import scala.io.Source
import scala.collection.mutable.ArrayBuffer

这是一个带有方法的类和一个带有匿名函数的映射,用于计算字符串中的分隔符

class DataValidation(datasetPath: String, datasetName: String, separator:    
String, encoding: String, sc: SparkContext) extends Serializable {

// open file and load distribute... and try playing around with it...
// RDD data declaration, reading dataset on RDD without header

var dataset = datasetPath + "//" + datasetName + ".csv"

def textfile_encoding(datasetIn: String, encodingIn: String) : RDD[String] = {
var characters = ArrayBuffer[String]()
for (line <- Source.fromFile(dataset, encoding).getLines()) {
characters += line
}
sc.parallelize(characters)

}
val rdd = this.textfile_encoding(dataset,encoding)
val separatorCount = rdd.map(_.count(_ == separator.charAt(0))) //error here
println("here")
}

然后是调用语句

val encoding = "utf8"
val datasetName = "InsuranceFraud"
val datasetSeparator = ";"

val sc = new SparkContext("local", "DataValidation Application")

val DataValidation = new DataValidation(datasetPath, datasetName,
datasetSeparator, encoding, sc)

我得到的错误是

Caused by: java.io.NotSerializableException: org.apache.spark.SparkContext
Serialization stack:
- object not serializable (class: org.apache.spark.SparkContext, value: org.apache.spark.SparkContext@2aa98145)
- field (class: $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$DataValidation, name: sc, type: class org.apache.spark.SparkContext)
- object (class $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$DataValidation, $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$DataValidation@3d93cd9c)
- field (class: $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$DataValidation$$anonfun$1, name: $outer, type: class $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$DataValidation)
- object (class $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$DataValidation$$anonfun$1, <function1>)
at org.apache.spark.serializer.SerializationDebugger$.improveException(SerializationDebugger.scala:40)
at org.apache.spark.serializer.JavaSerializationStream.writeObject(JavaSerializer.scala:47)
at org.apache.spark.serializer.JavaSerializerInstance.serialize(JavaSerializer.scala:81)
at org.apache.spark.util.ClosureCleaner$.ensureSerializable(ClosureCleaner.scala:312)
... 87 more

请注意以下行为

  1. 如果我按如下方式更改类中的语句,则一切正常。

    val separatorCount = rdd.map(_.count(_ == ';'))

  2. 如果我内联该方法,即只执行方法内的语句而没有方法,则一切正常。

最佳答案

我现在解决了这个问题..

由于我在 map 函数中使用了分隔符,因此尝试对整个类进行序列化。但是,方法 textile_encoding 无法序列化导致错误。

因此,我已将此方法移动到一个单独的类并在外部实例化它并将其传递给此类。

现在序列化没问题了。

当你遇到这个问题时,我认为你有三种解决方案:-

  1. 做我做的事。将方法移动到不同的类
  2. 编写您自己的闭包/序列化。 (还不知道)
  3. 预序列化有问题的方法(还不知道怎么做)

问候

阿米尔

关于java.io.NotSerializableException : org. apache.spark.SparkContext 序列化堆栈:- 对象不可序列化,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32064807/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com