有遇到过Flink CDC这个权限问题的么？
有遇到过Flink CDC这个权限问题的么，场景是从Kafka -> hive ,通过FlinkSQL实现，在dolphinscheduler调度。
Permission denied: user=dolphinscheduler, access=READ, inode="/warehouse/tablespace/managed/hive/":hdfs:hadoop:drwxrwx---？
写回答
-
使用 Flink CDC 采集数据时，会有以下几种权限问题：
对 Kafka 主题的读取权限
对 Kafka 主题的写入权限
对 MySQL 表的读取权限
对 MySQL 表的写入权限
如果没有这些权限，Flink CDC 将无法正常运行。以下是解决这些权限问题的一些方法：
为 Flink CDC 服务账户授予 Kafka 主题的读取权限和写入权限。
为 Flink CDC 服务账户授予 MySQL 表的读取权限和写入权限。
使用 Flink CDC 的 checkpoint.allowNonRestoreCheckpoints 配置，允许 Flink CDC 使用没有权限的 Kafka 主题和 MySQL 表进行数据采集。
如果您无法解决这些权限问题，可以联系 Kafka 和 MySQL 的管理员进行帮助。2023-10-20 15:26:04赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
