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

Flink CDC里sqlserver CDC 到mysql 有没有办法搞?3.0吗?

Flink CDC里sqlserver CDC 到mysql如果不想ds有没有办法搞?

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

Flink CDC里有没有其他简单的办法或者参数设置?

Flink CDC里mysql->doris, mysql表字段中含有-、换行符之类的特殊字符导致切分错误,从而实际字段个数和Doris的不一致。除了找到有特殊字符的字段手动处理掉,还有没有其他简单的办法或者参数设置?

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

Flink CDC里有什么好的办法能监听oracle数据变化吗?必须linux上部署吗?

Flink CDC里有什么好的办法能监听oracle数据变化吗?必须linux上部署吗?我现在想用oracle那个消息机制,一直没研究明白,监听不到。

问答 2024-03-25 来自:开发者社区

flink cdc 读取多个表,,打到ods层。后续需要单独重跑一张表,有办法吗?

flink cdc 读取多个表,,打到ods层。后续需要单独重跑一张表,有办法吗?就是原本用一个flink cdc任务 监听数据库多个表到kafka。现在下游某张表需要重新跑一下。

问答 2024-03-25 来自:开发者社区

flink mysql cdc有没有办法指定重跑部分的表呢?

flink mysql cdc有没有办法指定重跑部分的表呢?比如我数据库的字段修改了,想重新导入一下部分表。

问答 2024-03-19 来自:开发者社区

Flink CDC 里NameNode切换active/standby,导致代码报错,有办法避免吗?

Flink CDC 里NameNode切换active/standby,导致代码报错,代码中有办法切换节点避免吗?

问答 2024-03-11 来自:开发者社区

Flink CDC 里这个报错意思很明确,但不想改binlog_format配置,有办法吗?

Flink CDC 里这个报错意思很明确,但不想改binlog_format配置,有办法吗Caused by: org.apache.flink.table.api.ValidationException: The MySQL server is configured with binlog_format MIXED rather than ROW, which is required for ....

问答 2024-03-05 来自:开发者社区

flink cdc有什么办法判断任务是全量阶段还是增量阶段吗,想做一个监控,但找了圈,没有对应指标?

flink cdc有什么办法判断任务是全量阶段还是增量阶段吗,想做一个监控,但找了圈,没有对应指标?

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

Flink CDC里从kafka消费的时候顺序会乱,这时候就无法区分顺序了,这种情况有办法处理吗?

Flink CDC里从kafka消费的时候顺序会乱,这时候就无法区分顺序了,这种情况有办法处理吗?flink开窗排序可以解决,但遇到两个操作时间在同一时刻的咋办呢,有其它字段可以作标识区分吗?flink cdc到kafka是顺序的,但如果其中一条消息出现失败后重试,不会出现顺序问题嘛?如果从savepoint来重启,可能还会有重复数据吧,这时下游应该要去重取最新的offset吧?

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

Flink CDC里有办法yarn-session提交吗?提交的命令要怎么写啊?

Flink CDC里有办法yarn-session提交吗?提交的命令要怎么写啊?我一起启动了yarn-session,但是启动他找的还是8081 [hadoop@hadoop165 flink-cdc-3.0.1]$ bash bin/flink-cdc.sh mysql-to-doris.yaml --flink-home /data/bigdata/flink-1.17.1Caused by....

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

产品推荐

实时计算 Flink

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

+关注