问答 2025-04-11 来自:开发者社区

flink中checkpoint、io_tmp、rocksdb目录下会产生非常多的hardlink

1.flink中checkpoint、io_tmp、rocksdb目录下会产生非常多的hardlink引用,会有什么影响吗?2.io_tmp文件占用空间随时间越久会越占越大,有自动清理文件释放空间的机制吗?

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

Flink有个jar作业用的是异步io 但是现在都堵住那里了,怎么解决?

Flink有个jar作业用的是异步io 但是现在都堵住那里了,怎么解决?

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

实时计算 Flink版产品使用问题之在Flink算子内部使用异步IO可以通过什么办法实现

问题一:我注册了 5w 个不同 key 的定时器,但是Flink最终触发了 49997 有没有大佬能解释? 我注册了 5w 个不同 key 的定时器,但是Flink最终触发了 49997 有没有大佬能解释一下?为啥会少触发 3 个定时器? 参考答案: Flink 的定时器机制是用于感知并利用处理时间/事件时间变化的,它帮助 Flink 流应用具有反应性...

实时计算 Flink版产品使用问题之在Flink算子内部使用异步IO可以通过什么办法实现
问答 2024-07-02 来自:开发者社区

对于Flink CDC, MySQL的DATETIME的name是io.debezium.time?

对于Flink CDC, MySQL中的DATETIME的name是io.debezium.time.Timestamp,通过这个拿到的列是DATETIME类型?

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

在Flink CDC中我想用3.1的cdc,对应的io.debezium的包应该是哪个版本?

在Flink CDC中升级到1.15版本后,我想用3.1的cdc,对应的io.debezium的包应该是哪个版本?

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

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

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

文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之holo的io以及cpu使用较为稳定,sink端busy一直在20%左右,有时候50%,该如何优化

问题一:Flink的LOOKUP JOIN 支持子查询吗? Flink的LOOKUP JOIN 支持子查询吗? 参考答案: 关于本问题的更多回答可点击进行查看...

实时计算 Flink版产品使用问题之holo的io以及cpu使用较为稳定,sink端busy一直在20%左右,有时候50%,该如何优化
问答 2024-06-05 来自:开发者社区

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

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

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

Flink报错Caused by: java.io.IOException: write be...

Flink报错Caused by: java.io.IOException: write beyond end of stream

文章 2024-05-23 来自:开发者社区

实时计算 Flink版操作报错之报错:java.lang.ClassNotFoundException: io.debezium.connector.common.RelationalBaseSourceConnector,如何解决

问题一:Flink CDC中oracle的cdc遇到这个错误,有没有哪位朋友碰到过? Flink CDC中oracle的cdc遇到这个错误,有没有哪位朋友碰到过,Caused by: io.debezium.connector.oracle.logminer.parser.DmlParserException: Unknown supported SQL '/ No SQL_R...

实时计算 Flink版操作报错之报错:java.lang.ClassNotFoundException: io.debezium.connector.common.RelationalBaseSourceConnector,如何解决

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

X
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等