我在本地运行SPARK (我没有使用Mesos)，当运行像d3=join(d1，d2)和d5=(d3，d4)这样的连接时，我得到了以下异常"org.apache.spark.SparkException: awaitResult中的异常抛出“. org.apache.spark.SparkException: Exception thrown in awaitResult:
at org.apache.spark<
浏览 349提问于2016-07-28得票数 5
: Exception thrown in awaitResult: at org.apache.spark.rdd.RDDOperationScope在评论中，提到增加
浏览 5提问于2017-11-21得票数 0
Spark session available as 'spark'.: Exception thrown in awaitResult: at org.apache.spark.rpc.RpcTimeout.awaitResult(RpcTimeout.scala:75)
浏览 12提问于2021-11-03得票数 2
回答已采纳
1回答
但是当我试图将它提交给Spark独立集群时：我得到了“awaitResult抛出的异常”，如下所示： at org.apache.spark.rpc.RpcTimeout$$anonfun$1.applyOrElse(RpcTimeout.scaRpcTimeout.scala:59)
浏览 1提问于2018-02-02得票数 1
1回答
错误清除广播异常
、、、
该错误只发生在4-5分钟后，微批间隔为10秒.我使用Spark1.6.1在一个基于Kafka的ubuntu服务器上进行输入和输出流。请注意，我不可能提供最小的代码来重新创建这个错误，因为它不会发生在单元测试用例中，而且应用程序本身是非常大的。
at org.apache.spark.rpc.RpcTimeou
浏览 2提问于2017-07-18得票数 1
回答已采纳
8081 spark://192.168.0.38:7077SPARK_MASTER_HOST=192.168.0.38 .config(sparkConf) .getOrCreate()
在从IDE执行代码时，我在控制台中得到以下异常$.aw
浏览 1提问于2018-10-04得票数 2
1回答
:0.60\',\进行部署线程"main“java.lang.reflect.UndeclaredThrowableException中的异常在org.apache.hadoop.security.UserGroupInformation.doAs)由: org.apache.spark.util.ThreadUtils$.awaitResult(ThreadUtils.scala:226)：org.apache.spark.rpc.RpcTi
浏览 1提问于2020-01-24得票数 1
我试图运行火花-提交在远程主机，扭转是-远程主人需要身份文件。我的命令： at org.apache.spark.util.ThreadUtils$.awaitResult</
浏览 1提问于2021-12-15得票数 0
回答已采纳
;import org.apache.spark.api.java.JavaRDD;import org.apache.spark.streaming.Duration;
import org.apache.spark.streaming.api.java.JavaInputDStream: Exception thr
浏览 0提问于2017-04-10得票数 1
回答已采纳
SPARK 2.3抛出以下异常。有谁能帮帮忙！！我试着把罐子
308驱动程序错误org.apache.spark.deploy.yarn.ApplicationMaster -用户类引发异常: io.netty.buffer.PooledByteBufAllocator.metric-未捕获异常: org.apache.spark.SparkException:在org.apache.spark.deploy.yarn.Applica
浏览 1提问于2018-05-17得票数 8
在启用了spark身份验证和加密的spark独立集群上，我无法通过spark提交命令杀死spark应用程序。命令- bin/spark-class org.apache.spark.deploy.Client kill spark://host:7077 driver-20200728102235-0005.Getting error: Exception in thread "main" org.ap
浏览 33提问于2020-07-28得票数 0
我使用spark-structured-streaming作为消费者从kafka获取数据，按照指南参考https://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html期望的幻数在尾部80，65，82，49，但在读取它们时发现56，52，53，51]。我必须将它们移动到其他目录，并确保hive中的查询正常工作。但我不确定是否会因为移动而导致数据丢失。我知道spark</em
浏览 20提问于2019-05-25得票数 0
1回答
代码失败的原因如下：
/usr/local/spark/python/pyspark/serializers.py in _read_with_length(self,我试图在<
浏览 2提问于2016-08-17得票数 6
3回答
我试图将运行在虚拟机中的星火集群与10.20.30.50应用程序中的IP 7077和端口7077连接起来，并运行单词计数示例： at org.apache.spark.rpc.RpcTimeout$$anonfun$1.applyOrElse(RpcTimeout.scala167) ~[scala-library-2.11.8.jar:na]
浏览 4提问于2016-11-05得票数 15
回答已采纳
1回答
_1557254378595_0020_000002的AM容器退出，exitCode: 13失败，此attempt.Diagnostics: 2019-05-07 22:20:22.422发出容器启动异常用户应用程序退出状态1 19/05/07 22:20:21错误org.apache.spark.deploy.yarn.ApplicationMaster:未声明异常: org.apache.spark.SparkException:异常抛入awaitResult:
浏览 3提问于2019-05-07得票数 1
我一直在尝试在k8s上部署Spark2.4，并希望在驱动程序和执行器之间建立一个安全的远程过程调用通信通道。正在使用以下配置参数作为spark-submit的一部分spark.authenticate.secret goodCaused by: org.apache.<e
浏览 8提问于2018-12-11得票数 1
1回答
我的代码类似于 .schema(df_schema)\df2Spark structured streaming不支持这样的链式查询吗？据我所知，我没有做任何分支。编辑：
通过从dfc行中删除count()，我从query.awaitTermination()调用中得到了一个新的错误StreamingQueryException: Except
浏览 8提问于2018-03-02得票数 1
我在一个码头容器中运行了一个火花群集。我有一个吡火花简单的例子程序来测试我的配置，它运行在我的桌面上，在码头容器外。火花控制台获取并执行作业并完成作业。然而，pyspark客户端永远不会得到结果。22/03/05 11:42:23警告ProcfsMetricsGetter:尝试计算页面大小时的异常，因此停止了对ProcessTree度量的报告22/03/05 11:42:28警告TaskSchedulerImpl如果我单击服务器上的杀死链接，pyspark程序将立即获得：
22&#
浏览 3提问于2022-03-05得票数 0
import spark.implicits._
("2019-01-01 00:00:00", "7056589658"),不幸的是，它会引发错误：
org.apache.spark<
浏览 0提问于2019-05-02得票数 1
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
