SparkSpark cache 报错 Exception thrown in awaitResult

Posted 2021-05-16 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了SparkSpark cache 报错 Exception thrown in awaitResult相关的知识，希望对你有一定的参考价值。

文章目录

1.概述
2.场景1
- 2.1 概述
- 2.2 源码分析

在这里插入图片描述

1.概述

2.场景1

2.1 概述

写了一段代码，如下，但是运行的时候，时不时报错

在这里插入图片描述
错误如下

2.2 源码分析

根据报错信息找到如下

以上是关于SparkSpark cache 报错 Exception thrown in awaitResult的主要内容，如果未能解决你的问题，请参考以下文章

SparkSpark运行时产生的临时目录的问题

SparkSpark Class is not registered joins UnsafeHashedRelation kryo

SparkSpark kafka because consumer rebalance same group id joined different streaming

SparkSpark的一个案例 Encountered removing nulls from dataset or using handleInvalid = “keep“ or “skip“(代码

SparkSpark 及 Scala 语法简要介绍