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

处理Flink任务的时候,如何获取到MYSQL日志记录的BINLOG时间?

处理Flink任务的时候,如何获取到MYSQL日志记录的BINLOG时间?

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

flink cdc消费binlog报错,解析日期格式失败大家有遇到过吗?针对这种情况怎么设置默认值?

flink cdc消费binlog报错,解析日期格式失败大家有遇到过吗?针对这种情况怎么设置默认值? java.time.format.DateTimeParseException: Text '0000-00-00 00:00:00' could not be parsed

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

Flink消费binlog时能跳过指定的库表吗

Flink消费binlog时能跳过指定的库表吗

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

实时计算Flink报错The connector is trying to read binlog

实时计算Flink报错The connector is trying to read binlog xxx use a snapshot when needed.

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

Flink的Hologres源表开启binlog时cdc与非cdc模式的区别

Flink的Hologres源表开启binlog时cdc与非cdc模式的区别

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

Flink 大佬我这个权限是不是不够?还是怎么回事?还是binlog没有给我这个用户权限

Flink 大佬我这个权限是不是不够?还是怎么回事?还是binlog没有给我这个用户权限

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

在flink sql中用mysql cdc 同步数据, 每一张表同步都会创建一个binlog dum

在flink sql中用mysql cdc 同步数据, 每一张表同步都会创建一个binlog dump. 这样对上游业务可能会造成影响, 有相关配置可以实现一个实例对应一个dump线程吗?我在cdc官方文档 没有找到相关的配置

问答 2022-11-17 来自:开发者社区

为什么2.3的flink cdc 抽的binlog的时间是0?

为什么2.3的flink cdc 抽的binlog的时间是0?

问答 2022-11-13 来自:开发者社区

flink-cdc 在抽取mysql binlog,运行一段时间 source 就报java.uti

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2022-10-30 来自:开发者社区

flink cdc内置了kafka 监听binlog文件的时候 是把所有监听的数据写入kafka的

还是只是记录偏移量 数据还是从biglog取的

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