雪哥哥_个人页

2022年11月

• 11.17 20:02:05
  提交了问题 2022-11-17 20:02:05

  有一个问题 flink cdc 使用sql 进行group by 录入的时候，长时间会造成内存溢出吗

• 11.17 20:00:52
  提交了问题 2022-11-17 20:00:52

  mysql cdc 2.3.0从savepoint动态加表，我发现那个savepoint只能是，从头

• 11.17 20:00:34
  提交了问题 2022-11-17 20:00:34

  延迟数据获取到侧边流，可以获取任何时间段的超时数据吗？

• 11.17 19:59:40
  提交了问题 2022-11-17 19:59:40

  升级后报这错误 有遇到的吗？flink1.16 cdc2.3

• 11.17 19:58:39
  提交了问题 2022-11-17 19:58:39

  flinkcdc同步oracle时，能否同步其ddl语句？如何设置？

• 11.17 19:58:21
  提交了问题 2022-11-17 19:58:21

  有遇到过MongoCursorNotFoundException的问题吗？我有减少batchSize

• 11.17 19:57:54
  提交了问题 2022-11-17 19:57:54

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

• 11.17 19:56:54
  提交了问题 2022-11-17 19:56:54

  oracle cdc 是实时解析的吗？

• 11.17 19:56:34
  提交了问题 2022-11-17 19:56:34

  各位，请问一下，insert......select ,如果要用数据源的一个序列怎么处理？

• 11.17 19:55:06
  提交了问题 2022-11-17 19:55:06

  flink SQL能获取到op字段在select里面查出来吗？

• 11.14 22:30:25
  提交了问题 2022-11-14 22:30:25

  为什么插入语句的ts_ms是0，有大佬知道吗?

• 11.14 22:30:05
  提交了问题 2022-11-14 22:30:05

  有遇到这个错的吗？tm连接jm超时了，导致这个tm上的任务全挂了

• 11.14 22:29:37
  提交了问题 2022-11-14 22:29:37

  flink1.14的cdc如何写啊，由于flink-table-planner-blink_2.12

• 11.14 22:28:32
  提交了问题 2022-11-14 22:28:32

  有没有 pg 的 dba,咨询个问题。select * from table where ywh

• 11.14 22:28:20
  提交了问题 2022-11-14 22:28:20

  内存访问越界吗 这是。

• 11.14 22:28:05
  提交了问题 2022-11-14 22:28:05

  有大佬知道什么原因 并怎么处理这种情况吗？

• 11.14 22:27:01
  提交了问题 2022-11-14 22:27:01

  问一下FlinkSQL有什么可视化工具吗？

• 11.14 22:26:48
  提交了问题 2022-11-14 22:26:48

  如果同步的表结构有修改的话你们是怎么处理的啊？

• 11.14 22:26:35
  提交了问题 2022-11-14 22:26:35

  请问一下这两个参数的区别是什么？为什么使用第一个参数 ，ck保留个数一直是当前的ck位置？

• 11.14 22:25:21
  提交了问题 2022-11-14 22:25:21

  请教一下，如果一个表，不能再两个任务中公用查询吗？

• 11.14 22:24:48
  提交了问题 2022-11-14 22:24:48

  请问用flink14.5使用mysql cdc2.2.1时，似乎偶尔会出现无法执行sql的情况，大概

• 11.14 22:24:18
  提交了问题 2022-11-14 22:24:18

  我用service name 和 指定SID 都互相识别有误大佬们谁能帮忙看下

• 11.14 22:22:29
  提交了问题 2022-11-14 22:22:29

  各位大佬，oracle cdc使用的时候因为数据变化量比较大导致在flink同步的时候，整个orac

• 11.14 22:22:15
  提交了问题 2022-11-14 22:22:15

  数据库里某张表有20个字段，flink表只映射其中十个字段，用cdc连接，无关字段变动，会进行计算和

• 11.14 22:22:01
  提交了问题 2022-11-14 22:22:01

  2.3是不是不支持flink1.13版本呀？

• 11.14 22:20:47
  提交了问题 2022-11-14 22:20:47

  oracle cdc 使用默认的配置，解析时延迟非常高，有人知道原因吗？

• 11.14 22:20:36
  提交了问题 2022-11-14 22:20:36

  各位大佬，mysql只给select权限，怎么实现实时或者准实时的数据采集

• 11.14 22:20:14
  提交了问题 2022-11-14 22:20:14

  请教下各位，不知道flink cdc同步mysql数据库的数据跟datahub、dataworks或

• 11.14 22:19:09
  提交了问题 2022-11-14 22:19:09

  大佬们，cdc mysql 支持mysql5.6不？看官网说支持的，但是我跑了报出只支持5.7及以上

• 11.14 22:18:49
  提交了问题 2022-11-14 22:18:49

  cdc连接pg数据库，可以指定offset消费吗？

• 11.14 22:18:11
  提交了问题 2022-11-14 22:18:11

  使用flink-sql-connector-oracle-cdc-2.2.1.jar可以在sql-c

• 11.14 22:16:57
  提交了问题 2022-11-14 22:16:57

  flinkCDC对业务库在高峰期会有什么影响吗?

• 11.14 22:16:43
  提交了问题 2022-11-14 22:16:43

  请教一下，sql模式想获取修改前，修改后的数据这个怎么获取呢，没找到案例可以参考

• 11.14 22:16:25
  提交了问题 2022-11-14 22:16:25

  各位有个问题请假一下，我部署的是flink on yarn session ,3台机器，启动时候-n

• 11.14 22:15:14
  提交了问题 2022-11-14 22:15:14

  我有个问题，我之前的flinkcdc包是我之前自己编译的为了兼容1.15.2版本，然后我把包换成了昨

• 11.14 22:15:00
  提交了问题 2022-11-14 22:15:00

  有大佬测试2.3了吗 为什么flink1.13.1和2.3 测试会有Caused by: java.

• 11.14 22:14:21
  提交了问题 2022-11-14 22:14:21

  为什么mysql支持，oracle不支持呢？

• 11.14 22:13:20
  提交了问题 2022-11-14 22:13:20

  请教下，按照官网文档sink到mysql，一直保存不进去，控制台也没报错，有知道为什么的吗？

• 11.14 22:13:01
  提交了问题 2022-11-14 22:13:01

  flinkcdc 能否同步oracle的表结构改变。如何配置呢，mysql有includeSchem

• 11.14 22:12:43
  提交了问题 2022-11-14 22:12:43

  大佬们，咨询下，我这个分库分表的配置，这个10，只针对每个库吗？还是整体的？

• 11.14 22:11:41
  提交了问题 2022-11-14 22:11:41

  这种异常该怎么处理呢？

• 11.14 22:11:15
  提交了问题 2022-11-14 22:11:15

  mysql cdc2.1 到 hudi1.0，表里面的历史旧数据的增删改无法同步到hudi 有遇

• 11.14 22:11:01
  提交了问题 2022-11-14 22:11:01

  有大佬知道这个问题怎么解决吗？flink cdc 2.2.1

• 11.14 22:09:47
  提交了问题 2022-11-14 22:09:47

  各位大佬，我测试的flink1.13.5+flink-connector-postgres-cdc2

• 11.14 22:09:22
  提交了问题 2022-11-14 22:09:22

  SQL api使用cdc，一张表要占用pg的一个复制槽，这个问题怎么解决？

• 11.14 22:08:58
  提交了问题 2022-11-14 22:08:58

  请教下，我之前将数据通过DataHub再到DataWorks做离线数仓。现在想用flink cdc和

• 11.14 22:07:56
  提交了问题 2022-11-14 22:07:56

  flink cdc oracle跑起来以后，如果一段时间oracle表没有数据更新，连接就中断了。报

• 11.14 22:06:41
  提交了问题 2022-11-14 22:06:41

  sqlserver cdc啥时候支持无锁读取呀？

• 11.14 22:06:24
  提交了问题 2022-11-14 22:06:24

  请教下，flink-sql client 如何获取到插入之后的主键值？

• 11.14 22:05:56
  提交了问题 2022-11-14 22:05:56

  麻烦问下rowdata怎么转成string或者json