我环境
cdp版本:7.4.4
Spark版本:2.4.7.7.1.7.0-551
我的java代码是这样的
我提交命令:
./spark-submit --class com.abc.bdms.sparksql.SparkSQLDriver --master yarn --deploy-mode cluster --executor-memory 2G --num-executors 4 --keytab /home/bdms/flow.keytab --principal aa_qa/dev@HADOOP.COM /home/easyops/spark-sql-demo-1.0-SNAPSHOT.jar "select * from ods_employee_info_upload_bby2;"
但也有例外:
diagnostics: User class threw exception: org.apache.hadoop.ipc.RemoteException(java.io.IOException): Delegation Token can be issued only with kerberos or web authentication
我怎么才能解决它。
1条答案
按热度按时间qfe3c7zg1#
我的代码
及登录了