cloudera吧 关注:85贴子:169
  • 0回复贴,共1

cdh集群配置spark-sql报错有人遇到 一样的问题么

只看楼主收藏回复

22/09/09 01:27:14 INFO spark.SecurityManager: Changing modify acls groups to:
22/09/09 01:27:14 INFO spark.SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(root, hdfs); groups with view permissions: Set(); users with modify permissions: Set(root, hdfs); groups with modify permissions: Set()
22/09/09 01:27:15 INFO yarn.Client: Submitting application application_1662651094518_0001 to ResourceManager
22/09/09 01:27:15 INFO impl.YarnClientImpl: Submitted application application_1662651094518_0001
22/09/09 01:27:15 INFO cluster.SchedulerExtensionServices: Starting Yarn extension services with app application_1662651094518_0001 and attemptId None
22/09/09 01:27:16 INFO yarn.Client: Application report for application_1662651094518_0001 (state: ACCEPTED)
22/09/09 01:27:16 INFO yarn.Client:
client token: N/A
diagnostics: AM container is launched, waiting for AM container to Register with RM
ApplicationMaster host: N/A
ApplicationMaster RPC port: -1
queue: root.users.hdfs
start time: 1662658023076
final status: UNDEFINED
tracking URL: http://cdh04-144:8088/proxy/application_1662651094518_0001/
user: hdfs
22/09/09 01:27:17 INFO yarn.Client: Application report for application_1662651094518_0001 (state: ACCEPTED)
22/09/09 01:27:18 INFO yarn.Client: Application report for application_1662651094518_0001 (state: ACCEPTED)
22/09/09 01:27:19 ERROR server.TransportRequestHandler: Error while invoking RpcHandler#receive() on RPC id 5769662690298158403
java.lang.ClassNotFoundException: org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages$RetrieveDelegationTokens$
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at org.apache.spark.serializer.JavaDeserializationStream$$anon$1.resolveClass(JavaSerializer.scala:67)
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1868)
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)
at org.apache.spark.serializer.JavaDeserializationStream.readObject(JavaSerializer.scala:75)
at org.apache.spark.serializer.JavaSerializerInstance.deserialize(JavaSerializer.scala:108)


IP属地:上海1楼2022-09-08 17:28回复