请问一下, flink cdc 集成oss 用来保存checkpoint 的时候,配置都加进去了. 但是报错Aliyun OSS endpoint should not be null or empty. Please set proper endpoint with 'fs.oss.endpoint'. 看代码没有使用传进去的configuration , 而是自己创建的一个. 这个应该怎么把自己的configuration替换进去?
在flink run 命令中添加
-Dfs.oss.endpoint=
-Dfs.oss.accessKeyId=
-Dfs.oss.accessKeySecret=
是生效的,在代码中确实没有加载进去,有解决方法嘛
在 Flink CDC 集成 OSS 来保存 checkpoint 时,需要将 fs.oss.endpoint
配置项设置为正确的 OSS 端点。这个配置项应该在 Flink CDC 的 Configuration
中添加。
如果您已经创建了自己的 Configuration
,您可以将以下代码片段添加到 Configuration
中以指定正确的 OSS 端点:
Properties confProps = new Properties();
confProps.setProperty("fs.oss.endpoint", "your-oss-endpoint");
Configuration config = new Configuration(confProps);
在这里,您需要将 your-oss-endpoint
替换为您实际使用的 OSS 端点。
一旦您将正确的 fs.oss.endpoint
配置项添加到 Configuration
中,Flink CDC 将使用它来保存 checkpoint。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和《 阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写 侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。
玻璃钢生产厂家玻璃钢可以做雕塑玻璃钢抓鱼雕塑海淀玻璃钢海洋雕塑玻璃钢雕塑名字深圳室内商场美陈供应商布朗熊玻璃钢雕塑定制浙江节庆商场美陈制作泰州玻璃钢雕塑定制价格玻璃钢雕塑雕塑价格平谷玻璃钢动物雕塑玻璃钢花盆低价玻璃钢雕塑能用云石胶固定浙江玻璃钢卡通雕塑长宁区通用玻璃钢雕塑价格行情凌河玻璃钢雕塑厂家海南玻璃钢雕塑厂家品质售后无忧豫莲花玻璃钢雕塑四大天王图片梅州玻璃钢卡通雕塑哪家便宜博爱玻璃钢雕塑定制北京走廊商场美陈订购兰州玻璃钢人物雕塑公司无锡定做玻璃钢造型雕塑商场美陈需要注意大连专业定做沈阳玻璃钢花盆户外玻璃钢雕塑哪家便宜深圳玻璃钢雕塑座椅天津商场室外美陈哪家好白山雕塑玻璃钢卡通江苏玻璃钢金属雕塑哪家好甘肃玻璃钢雕塑图片香港通过《维护国家安全条例》两大学生合买彩票中奖一人不认账让美丽中国“从细节出发”19岁小伙救下5人后溺亡 多方发声单亲妈妈陷入热恋 14岁儿子报警汪小菲曝离婚始末遭遇山火的松茸之乡雅江山火三名扑火人员牺牲系谣言何赛飞追着代拍打萧美琴窜访捷克 外交部回应卫健委通报少年有偿捐血浆16次猝死手机成瘾是影响睡眠质量重要因素高校汽车撞人致3死16伤 司机系学生315晚会后胖东来又人满为患了小米汽车超级工厂正式揭幕中国拥有亿元资产的家庭达13.3万户周杰伦一审败诉网易男孩8年未见母亲被告知被遗忘许家印被限制高消费饲养员用铁锨驱打大熊猫被辞退男子被猫抓伤后确诊“猫抓病”特朗普无法缴纳4.54亿美元罚金倪萍分享减重40斤方法联合利华开始重组张家界的山上“长”满了韩国人?张立群任西安交通大学校长杨倩无缘巴黎奥运“重生之我在北大当嫡校长”黑马情侣提车了专访95后高颜值猪保姆考生莫言也上北大硕士复试名单了网友洛杉矶偶遇贾玲专家建议不必谈骨泥色变沉迷短剧的人就像掉进了杀猪盘奥巴马现身唐宁街 黑色着装引猜测七年后宇文玥被薅头发捞上岸事业单位女子向同事水杯投不明物质凯特王妃现身!外出购物视频曝光河南驻马店通报西平中学跳楼事件王树国卸任西安交大校长 师生送别恒大被罚41.75亿到底怎么缴男子被流浪猫绊倒 投喂者赔24万房客欠租失踪 房东直发愁西双版纳热带植物园回应蜉蝣大爆发钱人豪晒法院裁定实锤抄袭外国人感慨凌晨的中国很安全胖东来员工每周单休无小长假白宫:哈马斯三号人物被杀测试车高速逃费 小米:已补缴老人退休金被冒领16年 金额超20万