雪哥哥_个人页

2022年10月

• 10.24 17:38:44
  提交了问题 2022-10-24 17:38:44

  为什么我设置检查点的存储路径的方法没有了？同样的flink环境，一个月前的项目还可以，

• 10.24 17:38:22
  提交了问题 2022-10-24 17:38:22

  我想问下，我的flink版本用的是1.14.6，如果使用cdc的话，是不是需要自己去编译呀，现在cd

• 10.24 17:37:56
  提交了问题 2022-10-24 17:37:56

  cdc流能进行join操作吗？

• 10.24 17:35:22
  提交了问题 2022-10-24 17:35:22

  请教个问题：Flink cdc支持采集oracle 备库吗？

• 10.24 17:35:01
  提交了问题 2022-10-24 17:35:01

  你们有遇到这种情况吗... 我有个cdc job 跑了三个月..今天停了下,从sp恢复后,,重新导出

• 10.24 17:34:46
  提交了问题 2022-10-24 17:34:46

  有主键，但是主键不是自增的大家有啥好的解法么？现在测试下来感觉速度比较慢。

• 10.24 17:34:09
  提交了问题 2022-10-24 17:34:09

  有没有遇到同步MySQL一直卡在某个binlog文件？数据库已经确认后续的binlog都生成了 io

• 10.24 17:33:37
  提交了问题 2022-10-24 17:33:37

  有人试过使用flinkcdc只读全量数据，不读增量数据吗？

• 10.24 17:33:17
  提交了问题 2022-10-24 17:33:17

  有遇到过同步MySQL的时候没有主键的问题吗？Caused by: org.apache.flink

• 10.24 17:33:00
  提交了问题 2022-10-24 17:33:00

  log.mining.strategy=redo_log_catalog 你们这个参数设置成这样

• 10.24 17:32:36
  提交了问题 2022-10-24 17:32:36

  遇到过这种bug吗https://github.com/ververica/flink-cdc-co

• 10.24 17:32:08
  提交了问题 2022-10-24 17:32:08

  我双流join一直不调用joinfunction函数 有知道怎么确定问题的吗？

• 10.24 17:31:53
  提交了问题 2022-10-24 17:31:53

  各位 在实际中使用flinkSQL 多吗？

• 10.24 17:31:33
  提交了问题 2022-10-24 17:31:33

  报这个错是什么原因吗？

• 10.24 17:31:13
  提交了问题 2022-10-24 17:31:13

  flink有api可以像 spark那样批出 kafka数据吗？

• 10.24 17:30:54
  提交了问题 2022-10-24 17:30:54

  flinksql可以用状态吗？ 把一些数据存在状态里，然后根据后面数据来更新状态里的数据或者取出来输

• 10.24 17:30:31
  提交了问题 2022-10-24 17:30:31

  你好，现在flink cdc 在增量阶段可以实现upsert到iceberg（hive）吗 ？我用f

• 10.24 17:30:03
  提交了问题 2022-10-24 17:30:03

  比如mysql连接器，目标sink也会执行这个删除操作对吗？

• 10.24 17:29:45
  提交了问题 2022-10-24 17:29:45

  请教，datastream api同步ddl时，如果多个并行度，怎么保证顺序呢？

• 10.24 17:29:30
  提交了问题 2022-10-24 17:29:30

  flink sql cdc mysql delete数据怎么过滤，还是说目标库自己会兼容

• 10.24 17:29:11
  提交了问题 2022-10-24 17:29:11

  flink cdc支持openguass吗 ？

• 10.24 17:28:51
  提交了问题 2022-10-24 17:28:51

  我用kafka-upsert作为源表, 数据格式为键值格式为 'key '/ 'value.for

• 10.24 17:28:26
  提交了问题 2022-10-24 17:28:26

  这个参数在什么场景下生效吗？database.history.store.only.monitore

• 10.24 17:27:58
  提交了问题 2022-10-24 17:27:58

  哪位知道这个错误是什么原因？

• 10.24 17:27:21
  提交了问题 2022-10-24 17:27:21

  想问下Oracle cdc 2.2.1 同步11g同步时间类型数据都超了8小时。有啥办法吗？

• 10.24 17:26:57
  提交了问题 2022-10-24 17:26:57

  请教个问题，我从mysql-cdc 到Kafka，报错，版本是flink 1.13.6 cdc版

• 10.24 17:26:35
  提交了问题 2022-10-24 17:26:35

  能不能指点一下mongoCDC有没有实现CheckpointListener，没有实现这个接口是不是

• 10.24 17:26:20
  提交了问题 2022-10-24 17:26:20

  这种是怎么指定ip啊，端口是通的只是ip是本地的

• 10.24 17:25:57
  提交了问题 2022-10-24 17:25:57

  flink- cdc 2.3，flink版本1.14，oracle连接器报错

• 10.24 17:25:30
  提交了问题 2022-10-24 17:25:30

  ，请教个问题。

• 10.24 17:24:58
  提交了问题 2022-10-24 17:24:58

  ，mysql同步多个表到es整合成一个索引，该咋实现，有没有案例

• 10.24 17:24:38
  提交了问题 2022-10-24 17:24:38

  请问下Flink CDC datastream 采集mysql binlog数据，如何每次重启的时候

• 10.24 17:24:22
  提交了问题 2022-10-24 17:24:22

  有遇过source端出现多个线程，而且获取重复数据的问题吗？

• 10.24 17:23:57
  提交了问题 2022-10-24 17:23:57

  当我使用flink cdc+ iceberg+hive同步数据，启用upsert时，提交sql jo

• 10.24 17:23:21
  提交了问题 2022-10-24 17:23:21

  网上说禁用jdk安全协议，我照做了还是不行

• 10.24 17:22:53
  提交了问题 2022-10-24 17:22:53

  这个警告是什么问题？

• 10.24 17:22:30
  提交了问题 2022-10-24 17:22:30

  这个 报错什么原因？

• 10.24 17:22:09
  提交了问题 2022-10-24 17:22:09

  我用官网的cdc代码进行测试，Flink cdc 消费不到 MySQL 中的数据。也不报错，程序也不

• 10.24 17:21:49
  提交了问题 2022-10-24 17:21:49

  谁有Flink CDC Oracle（LogMiner）到oracle的demo吗，想玩玩看什么效果

• 10.24 17:21:27
  提交了问题 2022-10-24 17:21:27

  flink从ck恢复 cdc报错了

• 10.24 17:21:01
  提交了问题 2022-10-24 17:21:01

  oracle connector 支持 连接oracle 19c 容器数据库 采日志吗？

• 10.24 17:20:46
  提交了问题 2022-10-24 17:20:46

  我想问下，我今天刚接触fink cdc,尝试监控Oracle 11g某张表的变化时，使用打印信息使用

• 10.24 17:20:14
  提交了问题 2022-10-24 17:20:14

  oracle 11g，有人遇到过这个错吗？原表有好几天没有更新数据

• 10.24 17:19:53
  提交了问题 2022-10-24 17:19:53

  ，麻烦问个问题。使用flinkcdc采集SQL server时 遇到 字段设置默认值时，插入为nul

• 10.24 17:19:28
  提交了问题 2022-10-24 17:19:28

  问大佬一个问题,tumbling window 的数据忽然来一个高的水位线会导致所有的窗口进行提交,

• 10.24 17:19:09
  提交了问题 2022-10-24 17:19:09

  谁有docker相关的资料，方便给分享一下

• 10.24 17:18:50
  提交了问题 2022-10-24 17:18:50

  请问一下这个日志级别怎么设置为INFO啊？

• 10.24 17:18:27
  提交了问题 2022-10-24 17:18:27

  想请问一下，flinkcdc同步mysql数据库（flink-connector-mysql-cdc

• 10.24 17:17:55
  提交了问题 2022-10-24 17:17:55

  dinky有人用过吗？

• 10.24 17:17:38
  提交了问题 2022-10-24 17:17:38

  有用obs做ckp存储的吗？