0

我的 Spark Streaming Kafka 接收器程序中出现以下错误：

 ERROR actor.OneForOneStrategy: org.jnetpcap.protocol.network.Ip4java.io.NotSerializableException

可能是什么原因？

4

2 回答 2

2

如果在 Spark Streaming 中启用了检查点，那么在 forEachRDD 中调用的函数中使用的对象应该是可序列化的。否则，将出现“错误 OneForOneStrategy。如果我们关闭检查点，代码将运行。

于 2014-12-15T05:29:41.300 回答
0

简而言之，此错误表明您的作业中的某些函数引用了一个不可序列化的对象（即org.jnetpcap.protocol.network.Ip4）。查看Databricks Spark 知识库中的“ERROR OneForOneStrategy”文章，了解如何发生此问题的示例以及各种解决方法/修复的讨论。

于 2014-12-14T08:16:55.837 回答