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

Flink任务的jar包打的是最小包,如何指定这个本地磁盘lib目录,能有效加载这些依赖包呢?

Flink任务的jar包打的是最小包,maven依赖的其他包在本地磁盘lib目录,flink启动脚本,在yarn上运行,如何指定这个本地磁盘lib目录,能有效加载这些依赖包呢?

问答 2024-06-26 来自:开发者社区

在Flink CDC中启动两个表数据库端磁盘读速率 40M/s ,请问这个有参数可以限制吗?

在Flink CDC中读取oralce 启动一个表的任务,数据库端磁盘读速率 20M/s,启动两个表数据库端磁盘读速率 40M/s ,请问这个有参数可以限制吗?请参考图片:

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
322 人已学 |
免费

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
955 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
518 人已学 |
免费
开发者课程背景图
问答 2024-06-25 来自:开发者社区

在Flink CDC中读取oracle 数据库端反馈磁盘io读的很高 请问这个应该如何解决?

在Flink CDC中读取oracle 数据库端反馈磁盘io读的很高 请问这个应该如何解决?

问答 2024-06-05 来自:开发者社区

在Flink CDC中现在的sql server 磁盘iops低,io很高,整体的优化思路是什么?

在Flink CDC中现在的sql server 磁盘iops低,io很高,如果想要把这个io降下来,整体的优化思路应该是怎样的?

问答 2024-04-14 来自:开发者社区

请教个Flink问题,会把starrocks 磁盘打满是什么原因?

请教个Flink问题,mysql同步到starrocks的时候配置了 'debezium.snapshot.mode' = 'when_needed',会把starrocks 磁盘打满是什么原因?如果不配置就会任务跑10几个小时然后提示没有配置snapshot.mode' = 'when_needed'

问答 2024-03-28 来自:开发者社区

Flink能否获取subtask的资源使用情况,例如CPU使用率,内存使用率,磁盘使用率。

Flink能够通过监控指标获取TaskManager的资源信息,我现在想要获取每个subtask线程的信息,我应该如何获取subtask的资源使用信息,有相关代码或者文档吗。感谢

问答 2023-12-24 来自:开发者社区

Flink CDCbinlog归档也不是存储磁盘上,为了延长自己可以灵活控制的消费时间和消费次数吗?

Flink CDCbinlog归档也不是存储磁盘上, push到kafka 就是为了延长自己可以灵活控制的消费时间和消费次数?

问答 2023-12-01 来自:开发者社区

Flink CDC使用Flinkcdc同步导致WAL一直生成不删除,然后磁盘爆满的情况啊?

Flink CDC遇到pg13版本开启WAL: logical级别,然后使用Flinkcdc同步导致WAL一直生成不删除,然后磁盘爆满的情况啊?CDC任务停掉,然后将pg中的复制槽删除,WAL就会自动清理了

问答 2023-11-30 来自:开发者社区

Flink这个kafka云产品能不能扩容磁盘?

Flink这个kafka云产品能不能扩容磁盘?

问答 2023-10-31 来自:开发者社区

Flink CDC oracle没有数据操作,但是磁盘一直在暴增这个可能是啥情况?

Flink CDC中oracle按照官网开启日志归档后, oracle没有数据操作,但是磁盘一直在暴增这个可能是啥情况?出现了很多的 .arc文件~~~~事实上并没有对数据库有频繁操作,oracle的归档操作

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注