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

在Flink CDC中,发到kafka下游再处理数据还是用算子处理完直接写到目标库里面?

在Flink CDC中,发到kafka下游再处理数据还是用算子处理完直接写到目标库里面?

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

实时计算 Flink版操作报错合集之CTAS(Create Table As Select)目标库为StarRocks时报错,该怎么解决

问题一:Flink的 CTAS 目标库为starrocks,为什么报错呢? Flink的 CTAS 目标库为starrocks,为什么报错呢? 参考回答: fe集群的问题,ctas不支持调试,不要用use语句。自己修改一下吧。 关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/612277 ...

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

Flink的 CTAS 目标库为starrocks,为什么报错呢?

Flink的 CTAS 目标库为starrocks,为什么报错呢?语句时照抄 https://help.aliyun.com/zh/emr/emr-on-ecs/user-guide/use-the-ctas-and-cdas-statements-of-realtime-compute-for-apache-flink-to-synchronize-data-from-an-apsaradb-....

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

在使用Flink CDC从MySQL进行实时同步至目标库的场景中,如何解决生产环境中的问题?

在使用Flink CDC从MySQL进行实时同步至目标库的场景中,如何解决生产环境中由于MySQL连接数过多而造成的源数据库压力过大的问题?特别是在Flink 3.0版本下,针对运行在YARN上的任务管理(而非Kubernetes),以及对于存量客户可能存在的SQL自定义需求和资源管理的案例呢?

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

Flink CDC在使用flink-cdc 从mysql 进行实时同步到目标库的方案中,这种怎么办?

Flink CDC中,想了解Flink 3.0是否提供了针对MySQL连接数限制的技术优化措施?

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

Flink CDC如果我只要针对某个数据库,解析cdc的事件,然后同步到目标库吗?

Flink CDC如果我只要针对某个数据库,开发一个不那么通用的同步工具,是不是可以直接参考对应数据库的flink-cdc-connectors,解析cdc的事件,然后同步到目标库?想做个oracle到mongo的,实时同步,不依赖flink啥的?

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

Flink CDC中我想用cdc同步新增的数据但是在测试的时为什么写入到目标库的时候数据减少了很多?

Flink CDC中我想用cdc同步新增的数据,更新和删除的不管, 但是在测试的时候发现,写入到目标库的时候数据减少了很多 ,有知道可能是什么原因的吗?没对数据做任何出处理, 就是 source - filter - sink。

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

还有一个Flink CDC问题,比如数据读出来后放到kakfa,然后自己sink 到目标库, 这?

还有一个Flink CDC问题,比如数据读出来后放到kakfa,然后自己sink 到目标库, 这个是自己拼接sql吗?这样是不是还要根据字段的类型来进行拼接?

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

大佬们Flink CDC中是不是oracle现在只能做源库不能做目标库?

大佬们Flink CDC中是不是oracle现在只能做源库不能做目标库?

问答 2023-05-14 来自:开发者社区

flink CDC只能一个一个的单表配置写入目标库吗?如果表很多岂不是很难受?没有提供相seatun

flink CDC只能一个一个的单表配置写入目标库吗?如果表很多岂不是很难受?没有提供相seatunnel那样的一个配置文件就可以实现多个表的同步处理?

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

产品推荐

阿里云实时计算Flink

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

+关注