1

我低于堆栈跟踪,执行程序丢失并创建新的执行程序连接。

INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users  with view permissions: Set(etlspark); groups with view permissions: Set(); users  with modify permissions: Set(sss); groups with modify permissions: Set()
**java.lang.IllegalArgumentException: requirement failed: TransportClient has not yet been set.**
    at scala.Predef$.require(Predef.scala:224)
    at org.apache.spark.rpc.netty.RpcOutboxMessage.onTimeout(Outbox.scala:70)
    at org.apache.spark.rpc.netty.NettyRpcEnv$$anonfun$ask$1.applyOrElse(NettyRpcEnv.scala:232)
    at java.lang.Thread.run(Thread.java:745)
Exception in thread "main" java.lang.reflect.UndeclaredThrowableException
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1713)
    at org.apache.spark.executor.CoarseGrainedExecutorBackend$.main(CoarseGrainedExecutorBackend.scala:284)
    at org.apache.spark.executor.CoarseGrainedExecutorBackend.main(CoarseGrainedExecutorBackend.scala)
Caused by: org.apache.spark.rpc.RpcTimeoutException: Cannot receive any reply in 10 seconds. This timeout is controlled by spark.rpc.askTimeout
    at org.apache.spark.rpc.RpcTimeout.org$apache$spark$rpc$RpcTimeout$$createRpcTimeoutException(RpcTimeout.scala:48)
    at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:216)
    at scala.util.Try$.apply(Try.scala:192)

这个堆栈跟踪的原因是什么?是因为主从机器java版本不同还是这与集群配置有关。请指导我,因为此错误消息出现的原因是什么?

4

0 回答 0