雪哥哥_个人页

2022年10月

• 10.30 09:58:28
  提交了问题 2022-10-30 09:58:28

  我使用的cdc是2.2.0版本，flink是1.14.3版本，自己编译的jar包。但是我允许gith

• 10.30 09:58:04
  提交了问题 2022-10-30 09:58:04

  请问cdc底层会产生这么一个sql嘛？

• 10.30 09:57:42
  提交了问题 2022-10-30 09:57:42

  flink-connector-redis使用的是jedis，性能可以吗？有人用lettuce重写吗

• 10.30 09:57:19
  提交了问题 2022-10-30 09:57:19

  mysql cdc 从initial开始消费，数据是对的，跑了几个小时，数据变少了，然后重启从ini

• 10.30 09:57:00
  提交了问题 2022-10-30 09:57:00

  遇到过这种情况吗？前几天跑还正常，今天突然不行了

• 10.30 09:56:38
  提交了问题 2022-10-30 09:56:38

  难道是其它的程序也会占用server id？

• 10.30 09:55:43
  提交了问题 2022-10-30 09:55:43

  mysql cdc跑着跑着会丢数吗？

• 10.30 09:55:22
  提交了问题 2022-10-30 09:55:22

  请问一下flinkcdc 怎么配置能同步到mysql的truncate操作呢？现在源表truncat

• 10.30 09:54:58
  提交了问题 2022-10-30 09:54:58

  有谁遇到过内存占用很大的情况么？

• 10.30 09:54:01
  提交了问题 2022-10-30 09:54:01

  这里需要哪里配置吗？

• 10.30 09:53:19
  提交了问题 2022-10-30 09:53:19

  flink-cdc同步表，结果一直提示这个警告，不同步数据是什么情况

• 10.30 09:52:35
  提交了问题 2022-10-30 09:52:35

  flinkcdc采集单表数据根据表中的时间字段做水位线 打印出来乱序的问题 在数据库该字段是有序

• 10.30 09:52:15
  提交了问题 2022-10-30 09:52:15

  flink cdc读取oracle数据，需要的最小权限列表是什么，DBA反馈给的权限过大，不同意这么

• 10.30 09:51:57
  提交了问题 2022-10-30 09:51:57

  一个mysql表，做两个source，serverId设置成不一样的范围值是否会报serveID重复

• 10.30 09:49:54
  提交了问题 2022-10-30 09:49:54

  mysql cdc sink到 adb，报这个错 cannot update pk column I

• 10.30 00:07:17
  提交了问题 2022-10-30 00:07:17

  你好有个疑惑怎么解决?

• 10.30 00:06:46
  提交了问题 2022-10-30 00:06:46

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

• 10.30 00:06:26
  提交了问题 2022-10-30 00:06:26

  cdc 进行全量初始化的时候，导致mysql连接超时，然后数据读取不全，如果只是抓取增量则不会出现这

• 10.30 00:06:02
  提交了问题 2022-10-30 00:06:02

  flinksql中没有 COLLECT_SET 函数吗？

• 10.30 00:05:36
  提交了问题 2022-10-30 00:05:36

  flink 读取mongo的时候，发过来的数据 source.ts_ms 时间戳不够精确（需求，一张

• 10.30 00:04:59
  提交了问题 2022-10-30 00:04:59

  flink CDC可以直接将mysql中的数据直接写入到hive中吗？

• 10.30 00:04:29
  提交了问题 2022-10-30 00:04:29

  使用sql-client 可视化端，怎么提交到指定的yarn session . 各位小伙伴有谁能支

• 10.30 00:04:14
  提交了问题 2022-10-30 00:04:14

  有设置checkpoint？

• 10.30 00:03:49
  提交了问题 2022-10-30 00:03:49

  mysqlcdc写入hudi有例子吗？

• 10.30 00:03:25
  提交了问题 2022-10-30 00:03:25

  请问有人知道datastream读取tidb时，快照数据能读到，增量数据读取不到啥原因？

• 10.30 00:02:55
  提交了问题 2022-10-30 00:02:55

  有个疑惑可以帮忙解决吗？

• 10.30 00:02:29
  提交了问题 2022-10-30 00:02:29

  这个会读取同步程序没运行期间mysql插入的数据吗？我测试每次执行同步程序，都是从

• 10.30 00:01:43
  提交了问题 2022-10-30 00:01:43

  请问有人知道在flink cdc读取oracle的数据表或视图时，这个oracle用户需要具备哪些权

• 10.30 00:01:19
  提交了问题 2022-10-30 00:01:19

  请帮忙看下，我调整了mysql的连接时间，还是会出现上述问题。有没有啥办法解决？

• 10.30 00:00:56
  提交了问题 2022-10-30 00:00:56

  咨询下cdc数据做拉链你们一般是怎么一个思路或流程。

• 10.30 00:00:38
  提交了问题 2022-10-30 00:00:38

  请问，FlinkCDC的postgre connector，支持startup.positiion吗

• 10.30 00:00:10
  提交了问题 2022-10-30 00:00:10

  请教下，这个问题有没有什么解决方案

• 10.29 23:59:36
  提交了问题 2022-10-29 23:59:36

  我们这个数据采集的，就这个表一直报这个什么情况？

• 10.29 23:59:12
  提交了问题 2022-10-29 23:59:12

  那在底层有什么开源技术统一所有的文件系统么？毕竟元数据都要统一管理

• 10.29 23:58:57
  提交了问题 2022-10-29 23:58:57

  架构上是把(Parquet、hudi、hdfs、iceberg、oss 等文件系统)全部统一管理么？

• 10.29 23:58:36
  提交了问题 2022-10-29 23:58:36

  ，这个问题有解决掉吗？

• 10.29 23:58:08
  提交了问题 2022-10-29 23:58:08

  大家湖仓一体有搞过吗？

• 10.29 23:57:44
  提交了问题 2022-10-29 23:57:44

  请教一下，使用initial并开启checkpoint后，cancel掉程序，修改监控表中记录，为什

• 10.29 23:57:07
  提交了问题 2022-10-29 23:57:07

  cdc双流join是不是必须要都全量一次才行

• 10.29 23:56:39
  提交了问题 2022-10-29 23:56:39

  这个红色代表啥意思啊？

• 10.29 23:56:09
  提交了问题 2022-10-29 23:56:09

  大家有遇到过吗？

• 10.29 23:55:48
  提交了问题 2022-10-29 23:55:48

  如果需要自定义格式解析，有啥需要注意的吗？

• 10.29 23:55:28
  提交了问题 2022-10-29 23:55:28

  2.3版本的心跳功能的interval配置好像不会生效？CDC的option中无论设置为多大，在de

• 10.29 23:55:02
  提交了问题 2022-10-29 23:55:02

  咨询 flink cdc 同步源端1张到2个目标端，这个有没有限制？

• 10.29 23:50:47
  提交了问题 2022-10-29 23:50:47

  使用flink-cdc-oracle， 我使用<dependency> <groupId>c

• 10.29 23:50:31
  提交了问题 2022-10-29 23:50:31

  flinksql 的source表是加了SASL_SSL的Kafka，作业跑在yarn上，这个jks

• 10.29 23:50:00
  提交了问题 2022-10-29 23:50:00

  oracle 表级的补充日志只能在特定的表中开启吗？

• 10.29 23:49:45
  提交了问题 2022-10-29 23:49:45

  是canal读文件快 还是 binlogclient接受的快？

• 10.29 23:49:28
  提交了问题 2022-10-29 23:49:28

  建表 的时候主动指定不同的复制槽名称吗？

• 10.29 23:48:47
  提交了问题 2022-10-29 23:48:47

  怎么禁止 执行数据库的初始一致快照？