问答 2022-02-15 来自:开发者社区

Spark:Scala模拟,Task不可序列化

我试图使用mockito进行单元测试一些scala代码。我想在本地运行spark,即在我的IntelliJ IDE中。这是一个样本 class MyScalaSparkTests extends FunSuite with BeforeAndAfter with MockitoSugar with java.io.Serializable{ val configuration:SparkConf....

问答 2022-02-15 来自:开发者社区

Spark Task不可序列化/没有为第三方Jar定义的类

我一直在谷歌或Stackoverflow上搜索一个星期,仍然无法找到一个好的答案。我有一个化合物数据集,我需要使用第三方Jar来读取SDF中的这些化合物(类似JSON的数据格式)。然后我必须计算不同化合物之间的相似性。读取和计算需要非常复杂的化学细节,所以我不能自己重现这个功能。也就是说,我必须使用第三方Jar在Spark上的映射函数中运行该函数。Jar文件名为JCompoundMapper。它....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

Apache Spark 中国技术社区

阿里巴巴开源大数据技术团队成立 Apache Spark 中国技术社区,定期推送精彩案例,问答区数个 Spark 技术同学每日在线答疑,只为营造 Spark 技术交流氛围,欢迎加入!

+关注