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

Flink CDC里我从一个kafka消费多种不同格式的json数据,接下来怎么办?

Flink CDC里我从一个kafka消费多种不同格式的json数据,生成不同的中间表再用flink sql关联宽表,写入到doris数据库。现在情况是:写入没有问题,但是从checkpoint恢复一直报错,请问这个怎么解决?并且现在一个job里面多个insert 任务,请问我要插入多个宽表的话,如何在一个job里面一个任务里面完成?

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

flink cdc去读sqlserver2016版本数据库的数据,可以使用什么版本的CDC连接器?

我用flink cdc去读sqlserver2016版本数据库的数据,可以使用什么版本的CDC连接器。flink是1.13.6版本的。另外CDC2.2.1的会有锁表问题吗?

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

Flink cdc读取sqlsever 初始化数据可以进来,但后续变更没有为啥?

Flink cdc读取sqlsever 初始化数据可以进来,但后续变更没有为啥?一直报这个。按照文档检查了cdc配置。

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

Flink CDC里修改一条数据,怎么就背压了啊?

Flink CDC里修改一条数据,怎么就背压了啊?没报错。调试就两张表,2条数据,这种情况要怎么处理啊?

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

flink cdc读SqlServer数据,无法读取增量有没有碰到过?

flink cdc读SqlServer数据,无法读取增量有没有大佬碰到过? SqlServer的CDC已经开启了 flink是1.13.6 CDC是2.2.1版本 SqlServer是2016版本

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

Flink CDC我也读不到数据,请问最后怎么解决的?

PostgresIncrementalSource我读不到数据,请问怎么解决?

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

做了一个flink cdc同步mysql和clickhouse数据,有没有扫描jar包的工具呢?

做了一个flink cdc同步mysql和clickhouse数据,结果发现有些第三方包可坑有蠕虫病毒,话说有没有扫描jar包的工具呢?

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

Flink CDC中Oraclecdc为啥对数据进行更新,会先出一个null,然后才是更新后的值?

Oraclecdc为啥对数据进行更新,会先出一个null,然后才是更新后的值?”

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

在flink cdc同步单表数据时,关闭后会导致数据不一致?什么情况下适合开启?

在flink cdc同步单表数据时,基于sql的实现方式中发现了作业DAG有个SinkMaterializer算子,检查checkpoint历史时发现该算子state越来越大,可以关闭吗?

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

Flink CDC里flink流作业1读取paimon表A数据插入另一张表,后面怎么做?

Flink CDC里flink流作业1读取paimon表A数据插入另一张表,paimon表A如果drop重建后,流作业1会假死,这种情况是不是必须得把流作业1重新启动?这个假死是正常情况吗,是因为flink作业还是读取的没重建表的snapshot?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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