爱喝咖啡嘿_个人页

2022年12月

• 12.27 14:53:19
  提交了问题 2022-12-27 14:53:19

  flinkcdc依赖100多兆，可以减少吗？

• 12.27 14:49:22
  提交了问题 2022-12-27 14:49:22

  copy.existing.pipeline,mongo-cdc 2.2以后为啥删了这个参数了吗？

• 12.27 14:49:10
  提交了问题 2022-12-27 14:49:10

  有正在使用flink1.15版本的大佬现身说法吗？要求java11？

• 12.27 14:48:59
  提交了问题 2022-12-27 14:48:59

  flink cdc可以走Iceberg保持一致性，但是hive表还是不能识别Delete的数据

• 12.27 14:45:51
  提交了问题 2022-12-27 14:45:51

  flink cdc source端能降低消费速度嘛？

• 12.27 14:45:40
  提交了问题 2022-12-27 14:45:40

  为什么我本地idea使用flink1.16，mysql cdc使用2.3.0监控不到数据变化？？？

• 12.27 14:45:30
  提交了问题 2022-12-27 14:45:30

  请问有人知道flinkcdc怎么降低binlog的读取速度吗？

• 12.27 14:40:04
  提交了问题 2022-12-27 14:40:04

  有人知道hive的存储系统hdfs怎么换成minio吗？？

• 12.27 14:39:55
  提交了问题 2022-12-27 14:39:55

  flink-cdc 有获取 source schema 转换成 avsc 文件的工具吗?

• 12.27 14:39:44
  提交了问题 2022-12-27 14:39:44

  怎么将从Oracle获取到的数据转为rowdata，这个有知道怎么操作的吗?多表同步的工作又卡了

• 12.27 14:37:03
  提交了问题 2022-12-27 14:37:03

  DataStream<RowData> source = env.fromElements("")，

• 12.27 14:36:53
  提交了问题 2022-12-27 14:36:53

  用oraclecdc2.3 跑到后面scn间隔很大，感觉解析不过来，有遇到这种情况吗

• 12.27 14:36:41
  提交了问题 2022-12-27 14:36:41

  Flink cdc是不是不支持BLOB和CLOB的类型？

• 12.27 14:35:05
  提交了问题 2022-12-27 14:35:05

  这个异常应该怎么解决呢？Exceeded checkpoint tolerable failure

• 12.27 14:34:42
  提交了问题 2022-12-27 14:34:42

  请问flinkcdc这种类型入不了es库，怎么解决？

• 12.27 14:32:58
  提交了问题 2022-12-27 14:32:58

  idea运行flink, 如何提交多个任务呀?

• 12.27 14:32:48
  提交了问题 2022-12-27 14:32:48

  flinkcdc这个作业经常性地重启为什么？

• 12.27 14:31:35
  提交了问题 2022-12-27 14:31:35

  'debezium.snapshot.mode' = 'never' 模式，为啥始终会多一条数据？

• 12.27 14:31:26
  提交了问题 2022-12-27 14:31:26

  flinksql的方式怎么能将变化前后的值都拿到？

• 12.27 14:31:15
  提交了问题 2022-12-27 14:31:15

  如何将变更数据写进hive表啊？

• 12.27 14:29:10
  提交了问题 2022-12-27 14:29:10

  postgres-cdc 支持断点续传吗？我看了mysql是支持的

• 12.27 14:28:48
  提交了问题 2022-12-27 14:28:48

  这个是我oracle归档没做好吗？

• 12.27 14:26:11
  提交了问题 2022-12-27 14:26:11

  CDC MySQL 携带默认值的问题有人解决吗？

• 12.27 14:25:59
  提交了问题 2022-12-27 14:25:59

  oracle cdc 取出来的时间戳 时区问题咋处理的？我这取出来总是加了8个小时。。。。

• 12.27 14:25:48
  提交了问题 2022-12-27 14:25:48

  大家都是用debezium自带的JsonDebeziumDeserializationSchema做

• 12.27 14:24:32
  提交了问题 2022-12-27 14:24:32

  CDC同步的时候，如果要修改表结构，任务不能停吗?

• 12.27 14:24:15
  提交了问题 2022-12-27 14:24:15

  mysqlcdc 报这个错 有人遇到过吗？

• 12.27 14:23:08
  提交了问题 2022-12-27 14:23:08

  写入es 有什么方法可以让其按主键更新吗？

• 12.27 14:22:47
  提交了问题 2022-12-27 14:22:47

  Oracle 11g benchMarkSQL 跑了事务后同步到虚谷count不一致是啥原因 ？

• 12.27 14:20:11
  提交了问题 2022-12-27 14:20:11

  把flink的依赖包中加入 flink-connector-jdbc_2.12-1.13.0.ja

• 12.27 14:19:57
  提交了问题 2022-12-27 14:19:57

  用flinkcdc取到mysql中的表写到holo中 flinksql上线后发现写入holo中的表只

• 12.27 14:18:05
  提交了问题 2022-12-27 14:18:05

  Flink cdc mysql 并行读取参数如何设置？

• 12.27 14:17:55
  提交了问题 2022-12-27 14:17:55

  mysql-cdc connetor 好像不能用于sink端只能是 source端是么？ Conne

• 12.27 14:17:42
  提交了问题 2022-12-27 14:17:42

  提交了一个pr，显示这个是什么情况？

• 12.27 14:15:10
  提交了问题 2022-12-27 14:15:10

  flink cdc数据写入iceberg（在flink sql上用的hive catalog）

• 12.27 14:14:57
  提交了问题 2022-12-27 14:14:57

  本地执行没问题，但是放在centos7上就会显示找不到 jdbc connector咋办?

• 12.27 14:13:48
  提交了问题 2022-12-27 14:13:48

  在flinksqlclient建doris中间表 查出来中文乱码 有什么设置可以解决吗？

• 12.27 14:13:02
  提交了问题 2022-12-27 14:13:02

  cdc 2.3 ，tm重启后，一直报错Caused by: java.lang.IllegalSta

• 12.27 14:12:52
  提交了问题 2022-12-27 14:12:52

  怎么才能让flink程序找到jdbc呢？

• 12.27 14:06:57
  提交了问题 2022-12-27 14:06:57

  tidb-cdc 支持 'table-name' = 'user_[0-9]+' 这样指定分表吗？

• 12.27 14:06:47
  提交了问题 2022-12-27 14:06:47

  现在程序用的datastream api 还是 table api 还是 sql 呢？

• 12.27 14:06:31
  提交了问题 2022-12-27 14:06:31

  请问下oracle11g 为用户赋权时GRANT SET CONTAINER TO flinkuse

• 12.27 14:04:45
  提交了问题 2022-12-27 14:04:45

  vscode扩展商店可以访问吗？我一直提示xhr failed ，试了很多方法还是这样，刷新DNS，

• 12.27 14:04:01
  提交了问题 2022-12-27 14:04:01

  用的flink 1.14，cdc 2.3版本，同步mysql中json格式数据，有的时候会乱码，目前

• 12.27 14:03:44
  提交了问题 2022-12-27 14:03:44

  sink端创建的表明明是 mysql_inventory.student_info_demo_sin

• 12.27 14:01:55
  提交了问题 2022-12-27 14:01:55

  请问flinkcdc最新版本实现整库同步了吗?

• 12.27 14:01:45
  提交了问题 2022-12-27 14:01:45

  cdc 会对外暴露指标让promethus 收集到吗？

• 12.27 14:01:34
  提交了问题 2022-12-27 14:01:34

  flink cdc读取oracle写入hudi并同步到hive时为什么timestamp类型的数据被

• 12.27 14:00:19
  提交了问题 2022-12-27 14:00:19

  flink SQL 放在centos7上提交作业出现的bug，本地环境运行没问题咋办？

• 12.27 14:00:06
  提交了问题 2022-12-27 14:00:06

  fink cdc oracle读取数据到 doris写入的时候直接到10G时一次性提交就卡住了