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

Flink CDC用timestamp模式启动的cdc任务,然后没有采集数据,tm日志一直打印这个?

Flink CDC用timestamp模式启动的cdc任务,然后没有采集数据,tm日志一直打印这个?

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

Flink CDC中timestamp模式启动任务,然后日志一直输出这个是啥问题呀?

Flink CDC中timestamp模式启动任务,然后日志一直输出这个是啥问题呀?

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

Flink CDC对checkpoint机制有研究的呢?

在Flink CDC中, Flink 1.13.6 的文件系统 checkpoint 模式下,同步记录增加会使 chk-x 目录内的 uuid 格式文件变大,该文件保存了同步的数据记录。尽管数据已同步至数据库,全量同步记录仍存于内存并在ck时持久化,这可能导致taskmanager内存超限而挂掉。有人研究过这个问题吗?

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

flink cdc 限制支持 ob oracle 模式吗?

flink cdc 限制支持 ob oracle 模式吗?

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

Flink CDC batch模式就是多分片多路复用了 这是哪里有设置么?

Flink CDC SingleThreadMultiplexSourceReaderBase stream模式下多分分片多路读 batch模式就是多分片多路复用了 这是哪里有设置么?

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

Flink CDC1.14 on k8s,session模式中的这个不能配置吗?

Flink CDC1.14 on k8s,session模式中的这个taskmanager的CPU不能配置request和limit吗?目前发现一定是要1核、2核这种整数且最低1核,是本身就不支持这样配置还是我的配置方法不对呢?

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

Flink目前只有 PER_JOB, SESSION 这两种提交模式是么?

Flink目前只有 PER_JOB, SESSION 这两种提交模式是么?

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

Flink CDC中pipeline 整库模式,有没有整合读日志的IO问题?

Flink CDC中pipeline 整库模式,有没有整合读日志的IO问题?我看在初始化全表模式,还是有多个binlogdump线程出现,结束进入增量模式,倒只有一个。理论上同一个数据源,用一个binlogdump,够用了。这个BUSY 100%,是一直在实时读binlog日志,所以100%? 还是因为SINK端消费慢才导致的100%

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

Flink CDC这个Oracle是只读模式,报这个错,怎么解决呢?

Flink CDC这个Oracle是只读模式,报这个错,怎么解决呢?不能创建log表

文章 2023-12-18 来自:开发者社区

Flink application on k8s 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊?

Flink在Kubernetes上的部署可以通过ConfigMap和Secret来提供额外的jar包和配置文件。具体步骤如下: 将所需的jar包打包成一个压缩文件,例如my-flink-job.jar.zip。创建一个ConfigMap,将压缩文件添加到其中。可以使用以下命令创建ConfigMap: kubectl create confi...

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

产品推荐

实时计算 Flink

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

+关注