- "特征平台咋做实时的？传参进去计算能做成实时的？
- application提交，报这个错是怎么回事啊
- "mongodb能否指定从最新oplog开始消费吗
- sqlServer cdc 今天突然接收不到消息了。要怎么排查原因呢？
- 各位大神flinkmysql，作业太多导致server-id冲突，这个又遇到相同问题的么？
- 放接触flink，现在用flink计算nginx日志做些统计，通过flume执行tail nginx的日志，输出到kafka然后flink消费，麻烦看下我的代码哪里有问题，现在的问题是flink的window没按照我的设想每间隔15秒就关闭，所以红框代码的结果stream一直print不出来
- flink读取mysql数据库遇到blob类型的数据了，会使用hex或着base64方法来进行读取，但是我们这边接收到数据，类型显示的是STRING，这个就不能识别它到底是什么类型了吗？
- "有mongodb-connector连接器吗？非cdc的
- 一般数据倾斜不都是会造成反压吗？为什么我这里却没有造成反压
- 源数据倾斜种种问题一般都是怎么解决？能提供一个思路吗？
- mongodb-cdc 读全数据库时，flinkUI是不是无法查看相关数据？
- "Could not find resource '/tools/maven/suppressions.xml'.
这个是哪个文件呢？ 我这单独pr了mongodb的代码 打包提示这个
14. cdc 接 postgres，求db那块的配置文档连接， 比如db conf调参 和扩展插件
4. 是否支持DDL 语句同步？schema同步呢？上游业务库设置rotation机制定期删除过期数据，但不想影响下游聚合库的话是否可以过滤这些truncate命令？
- 有没有flink cdc使用DataStreamAPI同步数据到hudi的案例代码啊,网上找了好久都找不到
- "求教各位大佬mysql 5.7为啥会连不上呢？binlog和授权都有8.0版本就可以"
- 配置中的state.savepoints.dir 不生效是什么原因吗？
- 有根据字段类型，自动生成建表语句的工具类吗？
- 跑了一个多小时报错Recovery is suppressed by NoRestartBackoffTimeStrategy，大佬们知道这是什么原因吗
- 我这里已经配置了数据库，为啥启动的时候还会扫描所有的库呢，哪位知道呢
- 有个很难处理的问题咨询下，我现在使用flinksql里面的cdc同步一个表到doris，要占用2个cpu，10个表就要20个cpu，怎么合理使用flinkcdc去同步表（占用更少的cpu）？
- flink cdc 2.2.1目前可以处理kafka嵌套json吗？是要定义json-schema还是 使用'format' = 'raw'？
- flinkcdc同步表的时候偶尔报 :A slave with the same server_uuid/server_id as this slave has connected to the请问一下群里的人有人知道什么问题吗
- mysql cdc 时间戳存在时区偏移，怎么处理呢
- 有遇到Mysql CDC获取的时间戳比实际的时间大八个小时的嘛，怎么解决？
- flink cdc sql 可以只同步全量batch跑吗？
- mongodb 磁盘原因导致触发oplog清理机制，cdc这边会报错，将会从头开始读数据，这个问题如何解决？
- 我在使用cdc读mongo的changestream的时候，时间间隔很短的情况，fulldocument中的值是一样的，update之前和update之后的fulldocument是一样的，都是最新那一条数据，并不会存在中间状态数据
- "上一条日志数据的fulldocument为什么会显示跟下一条fulldocument的数据一样，时间间隔不超过少于毫秒级别
- 请问使用flink cdc对数据库有影响吗？会对数据库产生大量的磁盘io吗？
- forward hash reblance 分别表是什么， ps 我知道hash 就是hash处理，reblance是在均衡
- 搭建了个demo。flinkcdc监控pg库，启动的时候日志将表的数据都打印了下，完了后对表做操作这边日志啥反应都没有
- "请问有人成功用cdc接postgres12不，db扩展的哪个插件？
- 有没有老师做过flinkcdc一次同步多个表
- "mongocdc有类似heartbeat的说法吗？
- 请问创建维表的的方式有哪些啊？像flink sql可以通过jdbc连接来创建，如果是通过stream api呢？继承RichSourceFunction吗
- 可以用flink-cdc抽取指定某天的mysql数据吗
- 我的并行度设置的是和Kafka的分区保持一致的，一般建议改成分区的倍数吗
- flink 怎么解决 一个表一个任务 对应的是一个数据库连接？ 怎么解决数据库连接数的较多的问题的 ？
- 假如传过来的 json 是个 jsonarray 对于 flink sql 的 scheam 如何定义呢？
- flink cdc Oracle会锁表吗？
- 我使用的是yarn Session上的SQL-client, 建表显示成功, 但是提交查询任务后就反馈这个错误了
- mysql-cdc如何同步一个库下所有表，同步单表没问题，但只指定库会报
- 有哪位小伙伴也遇到flink只做全量，没有做增量的问题的呀
- 多表同步问题你们都是怎么解决的，建多个作业吗，这样会占用数据库连接数和资源
- 我开启 flink cdc作业后 为什么 数据库 上那么多 binlog 解析器
- 用正则匹配月表，产生新表时，就会报错误。直接退出了
- "每次运行四五个小时之后就会报错这个DML语句无效这是什么问题啊
- cdc采集我手动关闭后添加采集的表，从savepoint启动会采集到新表的历史数据吗
- 使用flink cdc官方案例，读取mysql binlog日志 到 flink，为何没有输出？ 背景：flink1.12, cdc 2.2
