爱喝咖啡嘿_个人页

2022年12月

• 12.20 15:50:03
  提交了问题 2022-12-20 15:50:03

  flinkcdc 读取源数据时源表有default value 同步时会带defalut值如何解决

• 12.20 15:49:54
  提交了问题 2022-12-20 15:49:54

  dts中迁移，如果能够多个表迁移到一个索引中么？

• 12.20 15:48:24
  提交了问题 2022-12-20 15:48:24

  全量阶段sink到oracle特别慢，1万条数据一个批量，需要200多秒。有啥优化思路或方法么？

• 12.20 15:48:00
  提交了问题 2022-12-20 15:48:00

  flink cdc在 standalone集群上多启停几次metaspace会oom是为什么？

• 12.20 15:47:20
  提交了问题 2022-12-20 15:47:20

  docker启动 flink:1.16.0-java8 报错,有人碰到过吗?

• 12.20 15:45:55
  提交了问题 2022-12-20 15:45:55

  不能在savepoint文件恢复的时候加一张表吗？

• 12.20 15:45:21
  提交了问题 2022-12-20 15:45:21

  请问Flink CDC 的维度表可以做成广播的嘛？

• 12.20 15:44:39
  提交了问题 2022-12-20 15:44:39

  flink 支持瀚高数据库吗？

• 12.20 15:37:56
  提交了问题 2022-12-20 15:37:56

  发现flink cdc postgres部分字段没有按照字段名去生成insert into，而是数据

• 12.20 15:05:28
  提交了问题 2022-12-20 15:05:28

  Doris使用RowDataStream或者StringStream导入数据时，都支持批量插入？

• 12.20 15:05:03
  提交了问题 2022-12-20 15:05:03

  flink 版本 1.16 cdc 2.3.0 ， 遇到这个 Connection is not

• 12.20 15:04:34
  提交了问题 2022-12-20 15:04:34

  SQLserver => flink cdc => http 这链路能实现吗？

• 12.20 15:01:01
  提交了问题 2022-12-20 15:01:01

  SQLserver => flink cdc => scada 支持opcua 写入吗？

• 12.20 15:00:44
  提交了问题 2022-12-20 15:00:44

  MYSQL CDC 开并行是不是没有意义的？parallelism.default: 4 求解？

• 12.20 15:00:25
  提交了问题 2022-12-20 15:00:25

  请问sql-client使用sql文件的时候，能使用source 导入其他sql文件吗？

• 12.20 14:55:57
  提交了问题 2022-12-20 14:55:57

  "before":null,"after":{"ID":"AQ==","NAME":"sunyi",

• 12.20 14:55:05
  提交了问题 2022-12-20 14:55:05

  FLINK cdc好像大数据用的多，oltp数据库同步的方案也适合么？

• 12.20 14:54:44
  提交了问题 2022-12-20 14:54:44

  OceanBase的时候，有报这个错的同学吗？

• 12.20 14:47:29
  提交了问题 2022-12-20 14:47:29

  oracle cdc 的一个schema名称是C##CDCCONNECT 但是监听到事件后 # 变_

• 12.20 14:47:02
  提交了问题 2022-12-20 14:47:02

  有大佬oracle cdc上生产了吗，用了cdc后Oracle内存一直上涨啥情况哦？

• 12.20 14:46:47
  提交了问题 2022-12-20 14:46:47

  flink sql表定义中的事件时间支持计算列么？数据中有非法时间值`0000-00-00 00:0

• 12.20 14:45:47
  提交了问题 2022-12-20 14:45:47

  flink1.14+flink-cdc 2.2.1,遇到这个问题是怎么解决的？java.lang.

• 12.20 14:45:27
  提交了问题 2022-12-20 14:45:27

  请问下，finlk cdc 最高支持pg什么版本的呀？

• 12.20 14:45:13
  提交了问题 2022-12-20 14:45:13

  flinkcdc 读取binlog在指定了timestamp的情况下，启动时会耗费大量的时间读取bi

• 12.20 14:43:41
  提交了问题 2022-12-20 14:43:41

  在从mysql合宽表（left join）到iceberg的时候，iceberg commit 记录

• 12.20 14:43:22
  提交了问题 2022-12-20 14:43:22

  需要大量实时计算， cdc能支持么？ 有状态的

• 12.20 14:43:07
  提交了问题 2022-12-20 14:43:07

  sqlserver > flink cdc> kafka> flink> es 这链路 可行吗？

• 12.20 14:40:22
  提交了问题 2022-12-20 14:40:22

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

• 12.20 14:40:05
  提交了问题 2022-12-20 14:40:05

  有没有用cdc同步mongodb，稳定不？

• 12.20 14:39:51
  提交了问题 2022-12-20 14:39:51

  开启checkpoint之后，产生了很多chk-*的文件，占用空间很大，设置了 state.chec

• 12.20 14:37:55
  提交了问题 2022-12-20 14:37:55

  务启动后会将数据库存量数据一次性导入，但是增量数据要过20分钟才会开始同步，之后的数据都是实时同步，

• 12.20 14:37:39
  提交了问题 2022-12-20 14:37:39

  问下 阿里云的 dts 能否消费云下的binlog？

• 12.20 14:37:25
  提交了问题 2022-12-20 14:37:25

  出现db history topic or its content is fully or part

• 12.20 14:27:56
  提交了问题 2022-12-20 14:27:56

  flink获取after、before的数据字段怎么就只能过去到更新字段的数据？

• 12.20 14:26:59
  提交了问题 2022-12-20 14:26:59

  开启checkpoint之后，产生了很多chk-*的文件，占用空间很大，请问可以设置只保留最近几个吗

• 12.20 14:26:02
  提交了问题 2022-12-20 14:26:02

  启动flink cdc 2.3.0版本报这个错误有人知道怎么回事吗？

• 12.20 14:24:52
  提交了问题 2022-12-20 14:24:52

  flink测试时，一直报Exception in thread "main" java.lang.

• 12.20 14:22:42
  提交了问题 2022-12-20 14:22:42

  我用最新版本的CDC怎么initial没有增量数据了？

• 12.20 14:13:52
  提交了问题 2022-12-20 14:13:52

  请教下 oracle归档日志每天增长30G大吗，对oracle cdc有影响吗？

• 12.20 14:12:51
  提交了问题 2022-12-20 14:12:51

  我这边运行mysqlcdc报上下图错误。请问这是怎么回事，如何解决呀？

• 12.20 14:06:51
  提交了问题 2022-12-20 14:06:51

  mongocdc 用主键upsert是不是很占内存？

• 12.20 14:06:27
  提交了问题 2022-12-20 14:06:27

  he db history topic or its content is fully or par

• 12.20 14:05:51
  提交了问题 2022-12-20 14:05:51

  开启checkpoint之后，产生了很多chk-*的文件占用空间很大，请问有配置可以定时清理吗？

• 12.20 14:00:11
  提交了问题 2022-12-20 14:00:11

  我用cdc同步大表到kafka 用了2.3的切块 在数据fetch的时候报jvm堆内存溢出

• 12.20 13:59:44
  提交了问题 2022-12-20 13:59:44

  flink这是个什么问题啊，为啥提交jia报错，本地还不复现？

• 12.20 13:59:24
  提交了问题 2022-12-20 13:59:24

  JdbcSourceEventDispatcher 这个类的方法 schemaChangeRecor

• 12.20 13:53:42
  提交了问题 2022-12-20 13:53:42

  合宽表的时候出现check point failed 并且 GC overhead limit ex

• 12.20 13:51:32
  提交了问题 2022-12-20 13:51:32

  flink cdc sql 可以拿到数据的rowkind 信息吗？

• 12.20 13:51:19
  提交了问题 2022-12-20 13:51:19

  目前无主键的表用'scan.startup.mode' = 'latest-offset'采集增量是

• 12.20 13:50:51
  提交了问题 2022-12-20 13:50:51

  当前大家kafka版本用的多少啊？