问答 2025-02-17 来自:开发者社区

flink 读取oss-hdfs数据问题

Flink 尝试从 OSS 获取分区信息时,由于权限不足导致访问被拒绝。但是注意到这里的endpoint实际上是oss的endpoint,但是我的数据存储在oss-hdfs中,请问我该如何访问到oss-hdfs中的数据?已经在配置文件中设置fs.oss.jindo.endpoint: cn-beijing.oss-dls.aliyuncs.com

文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之怎么关闭HDFS的Web界面

问题一:Flink CDC里 任务重启由rocksdb状态后端改为hashmap行不行呢? Flink CDC里 任务重启由rocksdb状态后端改为hashmap行不行呢? 参考答案: Apache Flink 的任务在重启时更改状态后端,从 RocksDBStateBackend 更改为 HashMapStateBackend 并不是一个推荐的做法...

文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之Checkpoint Replicate Service 跨 HDFS 集群的副本制作是如何实现的

问题一:为什么使用 distcp 跨机房复制 Checkpoint 不是一个好的选择? 为什么使用 distcp 跨机房复制 Checkpoint 不是一个好的选择? 参考回答: 使用 distcp 跨机房复制 Checkpoint 不是一个好的选择,因为 distcp 会为每个复制任务启动一个重的 mapreduce 作业,而 Checkpoint ...

美团 Flink 大作业部署问题之Checkpoint Replicate Service 跨 HDFS 集群的副本制作是如何实现的
文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之HDFS 在 Flink 作业中面临什么压力

问题一:HDFS 在 Flink 作业中面临哪些压力? HDFS 在 Flink 作业中面临哪些压力? 参考回答: HDFS 在 Flink 作业中面临的压力主要来源于两个方面:一是随着业务增长导致的正常负载增加;二是大作业部署和 Checkpoint 期间带来的瞬时 RPC 请求高峰,可能导致 NameNode 的 RPC Call Queue 打满...

问答 2024-08-13 来自:开发者社区

在Flink CDC中,怎么没字段 hdfs上文件也是空的?

在Flink CDC中,怎么没字段 hdfs上文件也是空的?

问答 2024-07-31 来自:开发者社区

flink1.18 api流失写入是加载表提示hdfs路径下表不存在

先在flink sql客户端中建表,语句如下:CREATE TABLE hive_catalog.default.sample (id INT COMMENT 'unique id',data STRING NOT NULL,PRIMARY KEY(id) NOT ENFORCED) with ('format-version'='2', 'write.upsert.enabled'='true....

问答 2024-07-30 来自:开发者社区

为什么直接在 Flink 引擎中双写到两个 HDFS 集群不是一个好的选择?

为什么直接在 Flink 引擎中双写到两个 HDFS 集群不是一个好的选择?

问答 2024-07-24 来自:开发者社区

Flink指定chepoint为hdfs路径,启动job报错。有人遇到此问题吗?

Flink指定chepoint为hdfs路径,启动job报错。有人遇到此问题吗?

文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之Hadoop在将文件写入HDFS时,无法在所有指定的数据节点上进行复制,该如何解决

问题一:Flink CDC里flinkcdc写hudi的时候这个错误怎么弄? Flink CDC里flinkcdc写hudi的时候这个错误怎么弄? own Source) at org.apache.hadoop.hdfs.DF...

实时计算 Flink版操作报错合集之Hadoop在将文件写入HDFS时,无法在所有指定的数据节点上进行复制,该如何解决
问答 2024-07-15 来自:开发者社区

Flink报错:是不是必须要指向HDFS的目录?

Flink报错:The "yarn.provided.lib.dirs" should only contain dirs accessible from all worker nodes, while the "file:/etlApp/etl-dw-flink/lib/*" is local,是不是必须要指向HDFS的目录

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云存储

阿里云存储基于飞天盘古2.0分布式存储系统,产品多种多样,充分满足用户数据存储和迁移上云需求。

+关注