【发布时间】:2023-03-07 15:37:02
【问题描述】:
我重构了我的代码以使用 kryo 序列化。 除了反序列化某个类的几何属性外,一切正常。 没有抛出异常(我将“spark.kryo.registrationRequired”设置为 true)。 在调试时,我尝试收集数据,我发现几何中的数据只是空的。结果我知道反序列化失败了。 Geomtry 来自 - Any(scala) 类型,因为它可能是一个复杂的属性。 我的问题是为什么数据是空的,并且是否与属性的“任何”类型有联系。
更新:
类代码:class Entity(val id:String) extends Serializable{
变量索引:Any = null
var 几何:Any = null
}
几何包含圆心、形状和坐标(复杂对象)
【问题讨论】:
-
如果您希望我们提供帮助,您需要提供minimal reproducible example 来说明您的问题。文字很棒,但我们需要实际查看代码中发生的情况才能提供帮助。
标签: scala serialization apache-spark kryo