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

Flink CDC运行作业会导致数据库磁盘读的很高,出现IO性能瓶颈,如何解决?

Flink CDC中flink-sql-connector-oracle-cdc-2.3.0.jar 运行作业会导致数据库磁盘读的很高,出现IO性能瓶颈,大佬们如何解决?

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

异步io 可以作为自定义函数 在flink sql 中注册 作为函数正常使用吗?

异步io 可以作为自定义函数 在flink sql 中注册 作为函数正常使用吗? 官网没找到具体说明

问答 2023-09-20 来自:开发者社区

Flink CDC Async IO 超时导致检查点一直失败帮忙看一下嘛?

Flink CDC Async IO 超时导致检查点一直失败帮忙看一下嘛? 我这个是两个主要类方便帮忙看一下嘛?首先我的所有端口都是同的?

问答 2023-09-19 来自:开发者社区

Flink Async IO 超时导致检查点一直失败帮忙看一下嘛?

Flink Async IO 超时导致检查点一直失败帮忙看一下嘛? 我这个是两个主要类方便帮忙看一下嘛?首先我的所有端口都是同的

文章 2023-09-17 来自:开发者社区

大数据Flink异步IO

1 介绍1.1 异步IO操作的需求https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/asyncio.htmlAsync I/O 是阿里巴巴贡献给社区的一个呼声非常高的特性,于1.2版本引入。主要目的是为了解决与外部系统交互时网络延迟成为了系统瓶颈的问题。流计算系统中经常需要与外部系统....

大数据Flink异步IO
问答 2023-08-20 来自:开发者社区

Flink CDC2.4为什么会报 Could not initialize class io.?

Flink CDC2.4为什么会报 Could not initialize class io.debezium.connector.postgresql.PostgresConnectorConfig?

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

很多flink tm连接一个MySQL实例拉取binlog,会引起mysql负载和io过高吗?

很多flink tm连接一个MySQL实例拉取binlog,会引起mysql负载和io过高吗?

问答 2023-07-13 来自:开发者社区

请教各位一下,跑flink cdc样例程序,报错Caused by: java.io这个如何解决?

请教各位一下,跑flink cdc样例程序,报错Caused by: java.io.NotSerializableException: com.ververica.cdc.connectors.mysql.table.StartupOptions,这个如何解决?

问答 2023-06-18 来自:开发者社区

Flink CDC Caused by: io.debezium.connector.oracle?

Flink CDC Caused by: io.debezium.connector.oracle.logminer.parser.DmlParserException: DML statement couldn't be parsed. Please open a Jira issue with the statement '

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

大佬,Flink CDC中同一SQL中的多表,同源的情况下,IO有做优化整合吗,还是一个表拉一份全?

大佬,Flink CDC中同一SQL中的多表,同源的情况下,IO有做优化整合吗,还是一个表拉一份全量binlog?

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

产品推荐

阿里云实时计算Flink

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

+关注