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

实时计算 Flink版产品使用问题之Oracle数据库是集群部署的,怎么进行数据同步

问题一:使用 Flink CDC 是否有办法在 SQL 任务运行过程中查看或监控相关的日志信息? 在使用 Flink CDC 提交 SQL 任务到 Yarn 时,是否有办法在 SQL 任务运行过程中查看或监控相关的日志信息?另外在 Yarn 的 Web 界面上能否看到具体执行的 SQL 任务细节?我的目的是识别和定位哪些特定的 SQL 任务在 Yarn 集群上占用了大量内存资源。 ...

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

实时计算 Flink版产品使用问题之怎么实现从Oracle数据库读取多个表并将数据写入到Iceberg表

问题一:Flinkcdc3.0支持MySQLcdc同步到另一个MySQL吗? Flinkcdc3.0支持MySQLcdc同步到另一个MySQL吗? 参考答案: 不支持呀 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/639663 问...

实时计算 Flink版产品使用问题之怎么实现从Oracle数据库读取多个表并将数据写入到Iceberg表
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何去除源数据库的ID

问题一:Flink CDC里8的代码是不是不一样? Flink CDC里8的代码是不是不一样? 参考答案: 一样的, 同一套代码,换个数据库。 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/592337 问题二:一个FlinkCDC...

实时计算 Flink版产品使用问题之如何去除源数据库的ID
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何将增量数据直接写入下游数据库

问题一:Flink CDC里flink 能获取的当前任务运行的jar 名称吗? Flink CDC里flink 能获取的当前任务运行的jar 名称吗? 参考答案: 在Flink中,你可以通过以下方式获取当前任务运行的jar名称: Stream...

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

实时计算 Flink版产品使用问题之从MySQL数据库中捕获变更数据并进行实时处理如何按天分表同步CDC数据

问题一:Flink CDC MySQL按天分表同步CDC这块有什么好建议吗? Flink CDC MySQL按天分表同步CDC这块有什么好建议吗?主要是应该怎么配置订阅 参考答案: 在 Flink CDC MySQL 中按天分表同步 CDC,可以使用以下配置和建议: 1. 使用时间戳字段 :首先,确保您的 MySQL 表中有一个时间戳...

实时计算 Flink版产品使用问题之从MySQL数据库中捕获变更数据并进行实时处理如何按天分表同步CDC数据
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之JdbcSink是否支持将数据写入到MySQL数据库中

问题一:一样的代码,把Flink cdc从2.2升级到2.4.2同步不到pgsql的数据是什么原因? 一样的代码,把Flink cdc从2.2升级到2.4.2同步不到pgsql的数据是什么原因?也没有任何异常 参考答案: idea可以把日志配置文件配置好,可能有报错没打印出来 关于本问题的更多回答可点击进行查看: h...

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

实时计算 Flink版产品使用问题之源数据库一直在新增表或修改表结构,需要进行相应的修改和重启,该如何简化

问题一:flinkcdc采集oracle数据,存量阶段,哪位知道怎么解决这个问题呢? flinkcdc采集oracle数据,存量阶段,checkpoints一直在等待程序把存量数据采集完之后再进行checkpoint,但是这样会导致checkpoints失败,哪位大佬知道怎么解决这个问题呢? 参考答案: ...

实时计算 Flink版产品使用问题之源数据库一直在新增表或修改表结构,需要进行相应的修改和重启,该如何简化
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何启动多个jar包来监听同一个数据库的binlog,并针对不同的业务进行处理

问题一:flink cdc 3.0对切片key是字符串不能进行切分吗? flink cdc 3.0对切片key是字符串不能进行切分吗? 参考答案: source是复用原来的,你这个错误不是切分key...

实时计算 Flink版产品使用问题之如何启动多个jar包来监听同一个数据库的binlog,并针对不同的业务进行处理
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何实现MySQL数据库之间的实时同步

问题一:Flink CDC中这边需要做一个mysql到mysql的整库实时同步有什么好的第三方工具推荐吗? Flink CDC中这边需要做一个mysql到mysql的整库实时同步(源库可能出现表或字段变动,备库也需跟着变动),请问有什么好的第三方工具推荐吗? 参考答案: 阿里云 关于本问题的更多回答可点击进行查看: ...

实时计算 Flink版产品使用问题之如何实现MySQL数据库之间的实时同步
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之在同一个tm里面,任务超过20个后就显示连接池满,连不上数据库了,该怎么处理

问题一:在同一个tm里面,flink cdc的任务超过20个后就显示连接池满,这个问题如何修改配置解决? 在同一个tm里面,flink cdc的任务超过20个后就显示连接池满,连不上数据库了,这个问题如何修改配置解决? 参考答案: source选项里设置这个参数 ...

实时计算 Flink版产品使用问题之在同一个tm里面,任务超过20个后就显示连接池满,连不上数据库了,该怎么处理

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问