wenti_个人页

2023年02月

• 02.13 14:50:00
  提交了问题 2023-02-13 14:50:00

  mongodb cdc的时候 集合手动增加了索引 flinkcdc会报空指针错误，为什么？

• 02.13 14:49:36
  提交了问题 2023-02-13 14:49:36

  cdc一个online任务如果我新增或修改了表字段，需要再次生成SQL后，从chk恢复该任务吗？

• 02.13 14:48:28
  提交了问题 2023-02-13 14:48:28

  flink cdc connector里面有没有安全注入问题？

• 02.13 14:48:11
  提交了问题 2023-02-13 14:48:11

  flinkcdc 读取postgresql数据，只能读到存量数据，不能读到增量数据，这是哪里的问题？

• 02.13 14:47:38
  提交了问题 2023-02-13 14:47:38

  doris 连接器地址有吗？cdc 官方github上好像没有doris的连接器

• 02.13 14:44:13
  提交了问题 2023-02-13 14:44:13

  Flink CDC DataStream的方式可以捕获表结构变更，为何executeSql无法捕获？

• 02.13 14:43:04
  提交了问题 2023-02-13 14:43:04

  Flink CDC有没有哪款元数据管理工具实现，每隔一个时间周期对数据量监控报警的？

• 02.13 14:42:46
  提交了问题 2023-02-13 14:42:46

  请问pg的connecttor在哪里可以找呢？

• 02.13 14:42:31
  提交了问题 2023-02-13 14:42:31

  有人遇到过MySQL数据库库名和表名相同数据无法同步的问题吗？

• 02.13 14:40:47
  提交了问题 2023-02-13 14:40:47

  使用flink cdc监听一个mysql表的binlog，debezuim反序列化日志 报错，为什么

• 02.13 14:39:54
  提交了问题 2023-02-13 14:39:54

  flink如何查看所有application id？

• 02.13 14:39:44
  提交了问题 2023-02-13 14:39:44

  flinkcdc 读取postgresql数据，只能读到存量数据，不能读到增量数据，为什么？

• 02.13 14:38:24
  提交了问题 2023-02-13 14:38:24

  为啥Flink CDC官网只提截图的元数据？我想拿到binlog的操作类型，比如添加，修改，删除

• 02.13 14:38:07
  提交了问题 2023-02-13 14:38:07

  为啥Flink CDC官网只提截图的元数据？我想拿到binlog的操作类型，比如添加，修改，删除

• 02.13 14:37:20
  提交了问题 2023-02-13 14:37:20

  请教下，哪位有 flink cd解决方案？

• 02.13 14:35:54
  提交了问题 2023-02-13 14:35:54

  请问flink cdc对于postgre，不能从postgre同步到postgre吗？

• 02.13 14:33:01
  提交了问题 2023-02-13 14:33:01

  mysqlcdc使用的时候，如果表名是中文，增量记录不能同步到kafka，全量是可以。为什么？

• 02.13 14:32:38
  提交了问题 2023-02-13 14:32:38

  flink-cdc 链接mysql时候serverTimeZone正常，为什么制定上海就报错？

• 02.13 14:31:49
  提交了问题 2023-02-13 14:31:49

  请问一下有没flink cdc同步mysql，自动感知表结构变更并自动执行DDL的方案？

• 02.13 14:29:06
  提交了问题 2023-02-13 14:29:06

  flink cdc 2.2.0 flink 1.13.6有发现数据丢失的情况 怎么解决？

• 02.13 14:28:30
  提交了问题 2023-02-13 14:28:30

  cdc 2.3 源表字段类型为datetime 同步至到hive中后为long类型，怎么解决？

• 02.13 14:27:51
  提交了问题 2023-02-13 14:27:51

  Flink CDC 这个 1.14 版本不更新了么？

• 02.13 14:26:08
  提交了问题 2023-02-13 14:26:08

  为什么我flinkcdc读取的Oracle数据，然后打印，有些数字变成不明所以的字母了？

• 02.13 14:24:27
  提交了问题 2023-02-13 14:24:27

  大佬们 我想问一下 flinksql怎么断开算子链呀？

• 02.13 14:23:34
  提交了问题 2023-02-13 14:23:34

  Flink CDC官方确定 ddl目前还没有解析吗，只限于数据增删改变化吗？

• 02.13 14:23:15
  提交了问题 2023-02-13 14:23:15

  flinkCDC 支持数据重跑吗？自己设置偏移量这种

• 02.13 14:21:40
  提交了问题 2023-02-13 14:21:40

  请问一下，cdc不会写入归档日志吧？只会去读取归档日志喽？

• 02.13 14:21:21
  提交了问题 2023-02-13 14:21:21

  flink per_job mode模式下，通过提交任务完成，为什么JM没有正常退出？

• 02.13 14:20:29
  提交了问题 2023-02-13 14:20:29

  Flink CDC能不能感知表列的修改 和 表列的数据类型的修改？

• 02.13 14:19:20
  提交了问题 2023-02-13 14:19:20

  大家有没有flink connector for clickhouse，有没有官方git地址？

• 02.13 14:18:44
  提交了问题 2023-02-13 14:18:44

  大家有用cdc迁移oracle到mysql的场景吗？

• 02.13 14:18:25
  提交了问题 2023-02-13 14:18:25

  flink CDC 当第一次全量正常输出后，源表中数据任何变更就无法再被捕获到了，为什么？

• 02.13 14:16:41
  提交了问题 2023-02-13 14:16:41

  请问 es可以通过cdc的方式实时同步到hive吗，有没有大佬有试过这种方式？

• 02.13 14:16:02
  提交了问题 2023-02-13 14:16:02

  有用过doris on elasticsearch的吗，好使不？

• 02.13 14:15:48
  提交了问题 2023-02-13 14:15:48

  flinkcdc读取mongo每隔20天左右会出现这个问题，请问下应该怎么排除和解决呢？

• 02.13 14:14:05
  提交了问题 2023-02-13 14:14:05

  flink mysql 到 MySQL，哪位大神有样例？

• 02.13 14:13:26
  提交了问题 2023-02-13 14:13:26

  如何创建flink cdc与doris的连接，然后执行自定义拼接的增删改语句？

• 02.13 14:06:14
  提交了问题 2023-02-13 14:06:14

  Dubbo proto文件中，service方法首字母必须大写吗？

• 02.13 14:05:50
  提交了问题 2023-02-13 14:05:50

  dubbo-go一个原始日期java那边收到的不一样，是因为hessian的类型不对导致越界了吗

• 02.13 14:04:22
  提交了问题 2023-02-13 14:04:22

  dubbo-go一个原始日期与java那边收到的不一样，因为hessian的类型不对导致越界了吗？

• 02.13 14:03:20
  提交了问题 2023-02-13 14:03:20

  Dubbo有遇到过这个问题吗？

• 02.13 14:01:22
  提交了问题 2023-02-13 14:01:22

  为啥发了mqtt消息，订阅端必须重新链接才能收到之前的消息。不是实时接收到发过来的消息？

• 02.13 14:00:22
  提交了问题 2023-02-13 14:00:22

  Apache RocketMQ dockethub会提供arm架构的docker镜像吗？

• 02.13 13:59:23
  提交了问题 2023-02-13 13:59:23

  Apache RocketMQ一条事务消息 , messageId在手动重推之后就变了,为什么？

• 02.13 13:58:03
  提交了问题 2023-02-13 13:58:03

  请问下 如果Apache RocketMQ某个队列消息堆积严重 会影响到集群的吞吐量吗？

• 02.13 13:57:01
  提交了问题 2023-02-13 13:57:01

  直接从namesrv获取的路由，原客户端在获取不到的时候，应该这个段逻辑不一样吧？

• 02.13 13:56:25
  提交了问题 2023-02-13 13:56:25

  直接从namesrv获取的路由，原客户端在获取不到的时候，应该这个段逻辑不一样吧？

• 02.13 13:54:54
  提交了问题 2023-02-13 13:54:54

  请问rApache RocketMQ5 可以自动创建topic嘛?

• 02.13 13:54:19
  提交了问题 2023-02-13 13:54:19

  Apache RocketMQ使用ons，有的几分钟才消费到，这个怎么排查啊？

• 02.13 13:53:26
  提交了问题 2023-02-13 13:53:26

  Apache RocketMQ5.0的 autoCreateTopicEnable设置无效,为何？