爱喝咖啡嘿_个人页

2022年12月

• 12.21 11:11:47
  提交了问题 2022-12-21 11:11:47

  写个sql，两个datastream都是kafka生成的，然后join，结果写入mysq

• 12.21 11:10:54
  提交了问题 2022-12-21 11:10:54

  join 是在一定时间范围内的join ，这个时间需要设置吧？

• 12.21 10:59:58
  提交了问题 2022-12-21 10:59:58

  flink on yarn kerberos 七天过期，checkpoint失败了，大家是怎么处理的

• 12.21 10:59:29
  提交了问题 2022-12-21 10:59:29

  datastream如果是kafkasource生成的。这个datastream是否会把内存撑爆呢？

• 12.21 10:58:42
  提交了问题 2022-12-21 10:58:42

  Flink这里点了stop 之后，一直处于cancelling 状态，但是yarn界面看任务已经没了

• 12.21 10:57:34
  提交了问题 2022-12-21 10:57:34

  Flink写本地表是不是需要自己写代码, 去决定主键去写哪个本地表?

• 12.21 10:57:07
  提交了问题 2022-12-21 10:57:07

  clickhouse 用的repalacingmergerTree, 为什么数据没有根据主键去重,？

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

  flinkcdc2.3.0，哪个参数可以控制读取binlog的速度？是fetchSize吗？

• 12.20 16:29:08
  提交了问题 2022-12-20 16:29:08

  使用flinkcdc读取postgresql数据库，postgre需要的配置文件需要改哪些？

• 12.20 16:28:04
  提交了问题 2022-12-20 16:28:04

  oracle cdc 增量快照期间可以并行么？

• 12.20 16:27:48
  提交了问题 2022-12-20 16:27:48

  flink cdc这是什么情况啊？

• 12.20 16:27:26
  提交了问题 2022-12-20 16:27:26

  请教一下为什么用用kafka的client可以正常消费数据，但是用flink消费kafka就报错？

• 12.20 16:25:26
  提交了问题 2022-12-20 16:25:26

  Mongocdc2.2不支持采集多个库吗？

• 12.20 16:25:10
  提交了问题 2022-12-20 16:25:10

  在用flink cdc做etl插入的时候，出现ON CONFLICT跟我设置的主键字段不一致怎么排查

• 12.20 16:24:33
  提交了问题 2022-12-20 16:24:33

  用jdbc的方式连接就是正常的，用CDC就是报这个错误咋回事？

• 12.20 16:21:50
  提交了问题 2022-12-20 16:21:50

  oracle分区表是不是不支持初始化增量？

• 12.20 16:21:30
  提交了问题 2022-12-20 16:21:30

  业务用的flink mysqlcdc ，业务库进行了分库分表，怎么连接

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

  MYSQL-CDC FLINK SQL中 where 条件是不是在前期不起作用

• 12.20 16:19:49
  提交了问题 2022-12-20 16:19:49

  Flink CDC这个用户是否要 公用用户才行？

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

  oracle作为源端，多线程插入数据

• 12.20 16:18:18
  提交了问题 2022-12-20 16:18:18

  Flink 读取HDFS需要放开啥权限么？

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

  直接用Regular Join，结果集出现数据丢失的情况

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

  是不是仅仅只是flinksql的interval join才有此限制？

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

  Interval Join 只作用于insert操作，在CDC过程有提示是什么原因

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

  使用flink sql CDC 多表Interval Join 的时候， 报错

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

  mysql cdc删除数据是怎么标识的？

• 12.20 16:11:58
  提交了问题 2022-12-20 16:11:58

  有没有大佬实现动态表结构功能的？

• 12.20 16:10:48
  提交了问题 2022-12-20 16:10:48

  有人读过sqlserver的大表吗？

• 12.20 16:10:25
  提交了问题 2022-12-20 16:10:25

  flinkcdc在一套代码里同步数据可以搞2个mysql连接吗？

• 12.20 16:10:18
  提交了问题 2022-12-20 16:10:18

  arima预测输出能通过回归评估mae等指标吗？

• 12.20 16:08:38
  提交了问题 2022-12-20 16:08:38

  有没有什么方式可以动态设置并行度？

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

  hadoop02的机器上怎么读hadoop01上的存储路径呢？

• 12.20 16:07:48
  提交了问题 2022-12-20 16:07:48

  大佬有空帮忙检查下flink这个是哪里的问题？

• 12.20 16:05:54
  提交了问题 2022-12-20 16:05:54

  CDC能否实现数据回滚到任意时间点？

• 12.20 16:05:38
  提交了问题 2022-12-20 16:05:38

  在可视化建模中，文本分类训练组件保错，咨询使用方法，已经按照文档描述操作，依旧不成功咋办？

• 12.20 16:05:34
  提交了问题 2022-12-20 16:05:34

  有遇到过 flink SQL join 聚合结果缺失的情况吗？

• 12.20 16:02:28
  提交了问题 2022-12-20 16:02:28

  大佬们，flink这个bug，修复了吗？

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

  flink cdc 支持二次计算吗？还是就是一个采集?

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

  使用tidb cdc，报这个，有人遇到过没？

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

  我这边在参考官网jdbc实时消费hologres的数据案例，我把逛网的demo拷贝到本地发现deco

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

  Hologres新建表，字段id设为bigserial类型，且为主键，在插入数据时，id为空

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

  当前Hologres在公有云上买不到，提示资源不足咋办？

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

  MySQL连接器 bigint unsigned 无符号数映射会乱码怎么办？

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

  大佬有序列化flinkcdc数据到这个格式的序列化方法么？

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

  Lightning 马上下线了，有从Lightning迁移到Hologres比较快的方法吗？

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

  Holo或者Adb-Pg里没有（中文）文本相似度算法？

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

  Caused by: java.sql.SQLException？

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

  用flinksql-mysqlcdc拉mysql表，总共三张表，两张有数据一张没有数据为什么

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

  不能用日志的话,能增量抽取数据吗?oracle的

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

  flinkcdc oracle12c 插拔数据报错有遇到过的大佬没？