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

请教下,flink-cdc 里面,关联查询然后进入到doris数据库中。在flink中,关联查询的?

请教下,flink-cdc 里面,关联查询然后进入到doris数据库中。在flink中,关联查询的结果数据,会一直保存在内taskmanager的内存中吗?https://cloud.tencent.com/developer/article/1452854 类似这样的情况持续查询/聚合语句。另外测过join删除原表数据吗,能不能同步删除?left join 关联多个表

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

Flink CDC中我在使用flink-cdc pgsql 一段时间后发现无法捕获数据的情况怎么办?

Flink CDC中我在使用flink-cdc pgsql 一段时间后发现无法捕获数据的情况,pgsql检查复制槽状态一直为”catchup“。什么原因?

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

Flink CDC中有人再用flink-cdc 2.4.0版本嘛?

Flink CDC中有人再用flink-cdc 2.4.0版本嘛?

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

如果是没有读到包 会直接报 没有flink-cdc这个connetor吧?flink 14.2

如果是没有读到包 会直接报 没有flink-cdc这个connetor吧?flink 14.2 cdc 是2.3.0 这两个表会冲突吗

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

Flink-cdc-tidb是不是需要自己写tikv的序列化,Flink-cdc本身不包含序列化的?

问题1:Flink-cdc-tidb是不是需要自己写tikv的序列化,Flink-cdc本身不包含序列化的能力吗? 问题2:我是问序列化的那个,我们直接record.toString会乱码,使用isvalidUtf8查看得到,并非是utf8编码,但是我们的数据库是utf8编码的格式,就是卡在从byteString转为string这一步,jar包用的flink-sql,写的java代码,你点进去看....

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

Flink-cdc-tidb是不是需要自己写tikv的序列化,Flink-cdc本身不包含序列化的?

Flink-cdc-tidb是不是需要自己写tikv的序列化,Flink-cdc本身不包含序列化的能力吗

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

我本地使用的flink-cdc(目前flink的版本是:1.15.3,cdc的版本是:2.3.0)?

问题1:我本地使用的flink-cdc(目前flink的版本是:1.15.3,cdc的版本是:2.3.0)的dataStream测试从指定点位消费,但是抛出异常:可以看出来是什么原因吗? 问题2:我的flink就是从cdc数据到es,没有对字段进行显性的操作。而且我的inital和latest模式都是没有问题的呢

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

Flink-1.13.2 是和哪个版本的flink-cdc,2.3.0版本的吗?

Flink-1.13.2 是和哪个版本的flink-cdc,2.3.0版本的吗?

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

有没有flink sql 的例子 ? 我想不通过flink-cdc 去给一些表到ods

有没有flink sql 的例子 ? 我想不通过flink-cdc 去给一些表到ods,因为一些erp的数据库没有开启cdc

问答 2022-12-20 来自:开发者社区

flink1.14+flink-cdc 2.2.1,遇到这个问题是怎么解决的?java.lang.

flink1.14+flink-cdc 2.2.1,遇到这个问题是怎么解决的? java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava18/com/google/common/util/concurrent/ThreadFactoryBuilder

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注