spark报错Permission denied: user=test, access=WRITE, inode=/:hdfs:supergroup:drwxr-xr-x
项目背景
使用structured streaming消费kafka某个topic数据并写入hdfs上。本地运行没有错误,部署在yarn上报错。
问题排查
根据报错提示,是test用户没有权限操作hdfs的根目录,hdfs用户有权限。则使用hdfs用户进行部署,运行正常。发现在hdfs根目录下生成文件
/yarn/nm/usercache/hdfs/appcache/application_1560935858543_2777/container_e18_1560935858543_2777_01_000001/tmp/temporary-46dc51d5-226d-4b62-8f22-42eef565d138/*
发现该结构为checkpoint结构。又重新在本地运行了,仔细检查了,发现原来在本地也会生成checkpoint文件结构。文件目录是C:\Users\我的账号\AppData\Local\Temp\temporary-95fea160-e249-4694-b31b-6010fd42d45f/*
问题解决
df.writeStream.format("parquet").option("checkpointLocation", "path/to/checkpoint/dir") //此处需添加.option("path", "path/to/destination/dir").start()
spark报错Permission denied: user=test, access=WRITE, inode=/:hdfs:supergroup:drwxr-xr-x相关推荐
- 运行报错 Permission denied: user=Admin, access=WRITE, inode=/:root:supergroup:drwxr-xr-x
运行idea eclipse的时候报错 报错原因:第一次在本地运行wordCount的时候会报这种错,显示说没有权限,之前以为是电脑权限的问题,后来换成运行本地文件的时候不会报错,突然想到代码中的路径 ...
- Spark On Kubernetes报错Permission denied: user=root, access=WRITE, inode=/user/spark/log:hadoop:supe
Spark On Kubernetes 提交测试任务,driver pod 报错日志,如下: 19/11/06 07:38:05 INFO OutputCommitCoordinator$Output ...
- hbase启动报错Permission denied: user=xxx, access=WRITE, inode=“/HBase/MasterProcWALs“:root:supergroup:d
原因是因为在配置hadoop时没有添加相关配置项 应该在hdfs-site.xml文件中添加 dfs.permissions.enabled=false
- 报错Permission denied: user=root, access=EXECUTE, inode=“/tmp/hadoop-root“解决办法
方法1 修改文件权限给root hadoop fs -chown -R root:root /tmp 方法2 开放文件权限给所有人 hadoop fs -chmod -r 777 /tmp## 如果报 ...
- hadoop 权限错误 Permission denied: user=root, access=WRITE, inode=/:hdfs:super
关于不能执行Hadoop命令 并报权限问题执行错误1.Permission denied: user=root, access=WRITE, inode="/":hdfs:supe ...
- Permission denied: user=root, access=WRITE, inode=/:hadoopuser:supergroup:drwxr-xr-x
提示往HDFS写文件是不容许的. 在conf/hdfs-site.xml中加入: <property><name>dfs.permissions</name>< ...
- Hadoop报错AccessControlException: Permission denied: user=vincent, access=WRITE, inode=/:iie4bu:supe
尝试使用Java操作Hadoop,代码如下: /*** 使用Java API操作HDFS文件系统*/ public class HDFSAPP {public static void main(Str ...
- Hive报错:Hive JDBC:Permission denied: user=anonymous, access=EXECUTE, inode=”/tmp”
1.美图 今天使用JDBC来操作Hive时,首先启动了hive远程服务模式:hiveserver2 &(表示后台运行),然后到eclipse中运行程序时出现错误: Permission den ...
- Spark权限问题:Spark-submit运行报错 Permission denied user=deploy
1.视界 2.背景 Spark权限问题:Spark-submit运行报错 Permission denied user=deploy 这个问题是权限问题,只需要修改一下hdfs路径的权限就好了 原本的 ...
最新文章
- CentOS 6.5安装python3.3.4
- nginx反向代理监听非80端口造成的端口丢失解决方案
- Android单元测试读写文件,Android Studio单元测试:读取数据(输入)文件
- MySQL5.7 版本的安装、配置
- 从入门到掉坑:Go 内存池/对象池技术介绍
- opencv 叠加文字_Hello world.
- 在Spring中使用Redis
- Ubuntu根目录下各文件的功能介绍
- 在linux上禁用ip,防止frps转发的端口被爆破,并屏蔽境外ip
- Android开发笔记(三十一)SQLite游标及其数据结构
- 如何解决MFC读取文件在EditControl中显示是乱码的问题
- 小D课堂-SpringBoot 2.x微信支付在线教育网站项目实战_5-7.授权登录获取微信用户个人信息实战...
- 《System语言详解》——6. 语句种类
- 字符串常量池(StringTable)总结
- cad多个窗口并排显示_如何创建包含 CAD 导入和选择的仿真 App
- 理财笔记 - 给朋友的建议
- python 抽奖器_如何基于python实现年会抽奖工具
- 谈谈Jesse James Garrett提到的Ajax
- 如何将手机wifi网络通过USB共享给电脑使用
- 信息学奥赛一本通 1000:入门测试题目
热门文章
- ubuntu下查看文件(夹)大小的命令
- BUUCTF axb_2019_fmt32(格式化字符串漏洞)
- ZWAVE Alarm Report Command
- android 3d flip动画,3D Flip Board
- 路由器+Gdbserver+IDA Pro远程调试
- 做海外广告的都来看!收款方式有哪些?(包括Facebook audience network、Tik Tok 等平台)
- css3光束_CSS3实现光束和波浪
- matlab simulink四旋翼无人机模糊PID控制姿态
- 全国大学生电子设计竞赛【干货分享】
- 中国十大IC设计公司和十大最有潜力IC公司2010