爱喝咖啡嘿_个人页

2023年01月

• 01.03 16:01:27
  提交了问题 2023-01-03 16:01:27

  FlinkSQL Client中可以insert into到具体的值到hive中的表；insert

• 01.03 16:00:24
  提交了问题 2023-01-03 16:00:24

  flink mysql cdc 流api JVM (Heap/Non-Heap) Memory

• 01.03 15:59:44
  提交了问题 2023-01-03 15:59:44

  flink java api时候有没有办法实现一个main下多job？

• 01.03 15:59:24
  提交了问题 2023-01-03 15:59:24

  flinksql也是通过读取binglog来实现数据同步的吗？

• 01.03 15:57:38
  提交了问题 2023-01-03 15:57:38

  如果用flink sql提交同步任务，这种方式是读取binglog日志实现同步数据到目标库中的吗？

• 01.03 15:55:29
  提交了问题 2023-01-03 15:55:29

  flink mysql cdc 跑一段时间就会报 Terminating due to java.l

• 01.03 15:55:11
  提交了问题 2023-01-03 15:55:11

  stream方式同步是需要自己写java代码实现吗？

• 01.03 15:53:51
  提交了问题 2023-01-03 15:53:51

  公司商用环境的mysql 有200多张表需要同步， 如果我使用flinksql的方式进行数据同步，

• 01.03 15:53:09
  提交了问题 2023-01-03 15:53:09

  ./bin/start-cluster.sh 以这种方式启动，属于会话模式，单作业模式，应用模式？

• 01.03 15:52:00
  提交了问题 2023-01-03 15:52:00

  cdc 现在支持到flink1.16了吗?

• 01.03 15:51:12
  提交了问题 2023-01-03 15:51:12

  我做双流join，一直报这个错，有知道是什么原因的吗?

• 01.03 15:50:17
  提交了问题 2023-01-03 15:50:17

  flink-cdc 接入pssql从库是不是不支持?

• 01.03 15:48:49
  提交了问题 2023-01-03 15:48:49

  pgsql指定快照模式为initial_only，流任务会自动停止嘛？

• 01.03 15:48:19
  提交了问题 2023-01-03 15:48:19

  请问flink sql-client.sh界面中写的源和目标sql是基于binglog捕获数据变更的

• 01.03 15:47:36
  提交了问题 2023-01-03 15:47:36

  flinkcdc2.2采集mysql报错 你们用的mysql-connector-java版本是好多

• 01.03 15:45:44
  提交了问题 2023-01-03 15:45:44

  oracle cdc中同步需要几分钟，有碰到吗？

• 01.03 15:45:09
  提交了问题 2023-01-03 15:45:09

  flink cdc 2.1.1版本flink 1.13.6 oracle 11g，老是这个错误怎么办

• 01.03 15:42:44
  提交了问题 2023-01-03 15:42:44

  可以直接在jar包 后面写参数吗?

• 01.03 15:36:42
  提交了问题 2023-01-03 15:36:42

  flink sql从pg同步数据，在flink sql创建表，然后insert，重复操作几遍就报这个

• 01.03 15:33:10
  提交了问题 2023-01-03 15:33:10

  这边用cdc监听数据写入MySQL，为啥每秒才一二百条？

• 01.03 15:19:05
  提交了问题 2023-01-03 15:19:05

  我只想尝试做些简单的聚合统计(两张mysql表)，一张2万一张200万，为什么写入到es直接索引卡死

• 01.03 15:16:21
  提交了问题 2023-01-03 15:16:21

  使用的是2.2版本mysql cdc ，出现这个问题，是什么原因导致的？

• 01.03 15:14:46
  提交了问题 2023-01-03 15:14:46

  我用perjob方式提交作业，这个容器被分配了6G内存，然后我再次提交这个作业的时候，一直是等待咋办

• 01.03 15:12:10
  提交了问题 2023-01-03 15:12:10

  CDC同步pg库，一张表就占用一个slot吗？那大量表同步要如何设置？

• 01.03 15:11:35
  提交了问题 2023-01-03 15:11:35

  flink on yarn提交时，program arguments怎么设置呀？

• 01.03 15:10:23
  提交了问题 2023-01-03 15:10:23

  flinkcdc2.2.1在监控mysql其中一整个库的时候，不报错，但是checkpoint失败

• 01.03 15:09:53
  提交了问题 2023-01-03 15:09:53

  flink cdc可以把数据写入ES并指定其父文档么？

• 01.03 15:09:23
  提交了问题 2023-01-03 15:09:23

  当我在taskmanagers里，点一个task，点logs的时候，这个logs出来的内容，是log

• 01.03 15:07:56
  提交了问题 2023-01-03 15:07:56

  MongoCursorNotFoundException， 使用 mongocdc 2.3.0 会有

• 01.03 15:06:41
  提交了问题 2023-01-03 15:06:41

  ./flink-1.13.0/bin/flink run -d -t yarn-per-job -c

• 01.03 15:04:57
  提交了问题 2023-01-03 15:04:57

  有人知道 mySQLCDC 怎么 指定MySQL的驱动吗？MySQLCDC 版本 2.3.0

• 01.03 15:03:59
  提交了问题 2023-01-03 15:03:59

  flink:1.14.5-scala_2.12 请问大佬这是cdc版本与flink不兼容吗?初次使用

• 01.03 15:03:23
  提交了问题 2023-01-03 15:03:23

  有大佬见过这种错误嘛？

• 01.03 14:52:15
  提交了问题 2023-01-03 14:52:15

  用flinkcdc同步pg库，我的postgre表明明有主键，为啥还会报这个错啊

• 01.03 14:50:13
  提交了问题 2023-01-03 14:50:13

  请教下各位大佬：binlog阶段mysql cdc connector捕获到的ddl语句，虽然带有b

• 01.03 14:50:05
  提交了问题 2023-01-03 14:50:05

  我用运行flink sql作业：flink kafka conector->hudi->hive，对

• 01.03 14:49:00
  提交了问题 2023-01-03 14:49:00

  请问哪里有对于同步数据的字段解释说明或文档？

• 01.03 14:48:33
  提交了问题 2023-01-03 14:48:33

  cdc 从ck中启动后出现这个错误，应该怎么规避啊

• 01.03 14:47:41
  提交了问题 2023-01-03 14:47:41

  oracle cdc flink sql只能查到最新的一条，不能初始化，有遇到这个问题的同学吗？

• 01.03 14:45:40
  提交了问题 2023-01-03 14:45:40

  有大佬知道flink cdc这个bug应该怎么解决吗？

• 01.03 14:44:50
  提交了问题 2023-01-03 14:44:50

  mysql同步到mysql支持条件过滤吗？

• 01.03 14:44:08
  提交了问题 2023-01-03 14:44:08

  刚开始接触flink cdc，想问问按照文档里面代码，控制台疯狂打印是正常的嘛？

• 01.03 14:42:54
  提交了问题 2023-01-03 14:42:54

  我是想打印出这个source表的总记录数，但是这么写之后为啥还是没有结果呢？

• 01.03 14:39:14
  提交了问题 2023-01-03 14:39:14

  flink cdc能读取无主键的MySQL表吗？

• 01.03 14:38:55
  提交了问题 2023-01-03 14:38:55

  sink.buffer-flush.max-rows，这个值，一般设置多大合适呢？是根据部署的fli

• 01.03 14:38:17
  提交了问题 2023-01-03 14:38:17

  使用flink-oracle-cdc，遇到一个问题。报错： Caused by: java.lang

• 01.03 14:36:11
  提交了问题 2023-01-03 14:36:11

  flinkcdc这个是为啥呢？

• 01.03 14:34:41
  提交了问题 2023-01-03 14:34:41

  在程序里面加了这三个参数，然后SQL 解析就失败了咋办？

• 01.03 14:34:32
  提交了问题 2023-01-03 14:34:32

  如何使用flink实时解xml文件啊老师们?

• 01.03 14:33:29
  提交了问题 2023-01-03 14:33:29

  运行一段时间 就出现这个kafka事务问题