项目背景

使用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相关推荐

  1. 运行报错 Permission denied: user=Admin, access=WRITE, inode=/:root:supergroup:drwxr-xr-x

    运行idea eclipse的时候报错 报错原因:第一次在本地运行wordCount的时候会报这种错,显示说没有权限,之前以为是电脑权限的问题,后来换成运行本地文件的时候不会报错,突然想到代码中的路径 ...

  2. 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 ...

  3. hbase启动报错Permission denied: user=xxx, access=WRITE, inode=“/HBase/MasterProcWALs“:root:supergroup:d

    原因是因为在配置hadoop时没有添加相关配置项 应该在hdfs-site.xml文件中添加 dfs.permissions.enabled=false

  4. 报错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## 如果报 ...

  5. hadoop 权限错误 Permission denied: user=root, access=WRITE, inode=/:hdfs:super

    关于不能执行Hadoop命令 并报权限问题执行错误1.Permission denied: user=root, access=WRITE, inode="/":hdfs:supe ...

  6. Permission denied: user=root, access=WRITE, inode=/:hadoopuser:supergroup:drwxr-xr-x

    提示往HDFS写文件是不容许的. 在conf/hdfs-site.xml中加入: <property><name>dfs.permissions</name>< ...

  7. Hadoop报错AccessControlException: Permission denied: user=vincent, access=WRITE, inode=/:iie4bu:supe

    尝试使用Java操作Hadoop,代码如下: /*** 使用Java API操作HDFS文件系统*/ public class HDFSAPP {public static void main(Str ...

  8. Hive报错:Hive JDBC:Permission denied: user=anonymous, access=EXECUTE, inode=”/tmp”

    1.美图 今天使用JDBC来操作Hive时,首先启动了hive远程服务模式:hiveserver2 &(表示后台运行),然后到eclipse中运行程序时出现错误: Permission den ...

  9. Spark权限问题:Spark-submit运行报错 Permission denied user=deploy

    1.视界 2.背景 Spark权限问题:Spark-submit运行报错 Permission denied user=deploy 这个问题是权限问题,只需要修改一下hdfs路径的权限就好了 原本的 ...

最新文章

  1. CentOS 6.5安装python3.3.4
  2. nginx反向代理监听非80端口造成的端口丢失解决方案
  3. Android单元测试读写文件,Android Studio单元测试:读取数据(输入)文件
  4. MySQL5.7 版本的安装、配置
  5. 从入门到掉坑:Go 内存池/对象池技术介绍
  6. opencv 叠加文字_Hello world.
  7. 在Spring中使用Redis
  8. Ubuntu根目录下各文件的功能介绍
  9. 在linux上禁用ip,防止frps转发的端口被爆破,并屏蔽境外ip
  10. Android开发笔记(三十一)SQLite游标及其数据结构
  11. 如何解决MFC读取文件在EditControl中显示是乱码的问题
  12. 小D课堂-SpringBoot 2.x微信支付在线教育网站项目实战_5-7.授权登录获取微信用户个人信息实战...
  13. 《System语言详解》——6. 语句种类
  14. 字符串常量池(StringTable)总结
  15. cad多个窗口并排显示_如何创建包含 CAD 导入和选择的仿真 App
  16. 理财笔记 - 给朋友的建议
  17. python 抽奖器_如何基于python实现年会抽奖工具
  18. 谈谈Jesse James Garrett提到的Ajax
  19. 如何将手机wifi网络通过USB共享给电脑使用
  20. 信息学奥赛一本通 1000:入门测试题目

热门文章

  1. ubuntu下查看文件(夹)大小的命令
  2. BUUCTF axb_2019_fmt32(格式化字符串漏洞)
  3. ZWAVE Alarm Report Command
  4. android 3d flip动画,3D Flip Board
  5. 路由器+Gdbserver+IDA Pro远程调试
  6. 做海外广告的都来看!收款方式有哪些?(包括Facebook audience network、Tik Tok 等平台)
  7. css3光束_CSS3实现光束和波浪
  8. matlab simulink四旋翼无人机模糊PID控制姿态
  9. 全国大学生电子设计竞赛【干货分享】
  10. 中国十大IC设计公司和十大最有潜力IC公司2010