爱喝咖啡嘿_个人页

2022年12月

• 12.21 13:09:05
  提交了问题 2022-12-21 13:09:05

  A表 left join B表后的结果写入upsert-kafka,下游统计时如何在窗口内获取到最新

• 12.21 13:08:37
  提交了问题 2022-12-21 13:08:37

  Flink这是什么情况啊？

• 12.21 13:06:53
  提交了问题 2022-12-21 13:06:53

  每5秒统计一次当天00:00到当前的时间,state=1的数据条数,当state=1变为2时,该条数

• 12.21 13:06:36
  提交了问题 2022-12-21 13:06:36

  Flink计算每10秒的时间点某个状态的数据有多少咋弄啊？

• 12.21 13:06:19
  提交了问题 2022-12-21 13:06:19

  Flink时间窗口统计后写mysql,业务系统来查这个表，会锁表吗？

• 12.21 13:05:13
  提交了问题 2022-12-21 13:05:13

  flink cdc oracle12c pdb出现“java.sql.SQLException: O

• 12.21 13:04:52
  提交了问题 2022-12-21 13:04:52

  flink中下图这两个有什么区别，应该怎么理解？

• 12.21 13:04:33
  提交了问题 2022-12-21 13:04:33

  flink中这种一直转圈是什么情况啊？

• 12.21 13:00:56
  提交了问题 2022-12-21 13:00:56

  clickhouse 配置了集群怎么不显示？

• 12.21 13:00:19
  提交了问题 2022-12-21 13:00:19

  1.15的flink，操作savepoint的时候，必须现有数据的情况下操作？

• 12.21 13:00:00
  提交了问题 2022-12-21 13:00:00

  flink是不是还不支持通过configuration来设置pod 软、硬亲和性和反亲和性？

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

  维表进行lookupjoin的时候，如果维表建表后不能直接使用还需要在加工在弄？

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

  使用 interval join 合并a,b两个表，这两个表是flink cdc的表，b表的更新在a

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

  发现sp一个问题，我复制作业的时候不会对作业名检测直接就复制成功了，当我去修改作业的时候在里面就提

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

  用CDC然后再cdc计算怎么关联维表？主表不是只能跟CDC来的维表关联?

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

  CDC的表怎么关联维表了 ？

• 12.21 12:53:55
  提交了问题 2022-12-21 12:53:55

  主表是Mysql CDC过来的表是不是没办法弄维表join?

• 12.21 12:49:33
  提交了问题 2022-12-21 12:49:33

  flink谁遇到过这种问题嘛？怎么解决啊？

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

  flink on k8s ，session的pod内 log文件夹是空的为啥呢？

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

  为什么split_index这个udf只能返回2000长度的字符串?

• 12.21 12:45:40
  提交了问题 2022-12-21 12:45:40

  如果代码有更新，重新传jar包，需要从savepoint恢复，sreampark 怎么将跳过--al

• 12.21 12:45:16
  提交了问题 2022-12-21 12:45:16

  flink如果想10秒往数据库里面写一次，开个windowall窗口指定处理滚动时间窗口

• 12.21 12:44:50
  提交了问题 2022-12-21 12:44:50

  flink这个报错是啥问题啊？

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

  session模式 ，可以单独配置每一个job的参数吗，比如checkpoint的地址？

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

  flink一直报这个错，是不是jar加错位置了？

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

  我es映射到hive外部表后，通过hive overwrite操作好像无法对表数据进行覆盖操作咋办？

• 12.21 12:04:50
  提交了问题 2022-12-21 12:04:50

  mysql的date类型，通过cdc后转成数字了，咋办？

• 12.21 12:04:31
  提交了问题 2022-12-21 12:04:31

  web ui上发现一个现象，cep每次要等到前面算子全部计算完过后才开始计算busy直接100%

• 12.21 12:03:52
  提交了问题 2022-12-21 12:03:52

  flink这个啥情况，读文件出现这个？

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

  clickhouse 提示： mremap memory chunk from 98.00 MiB

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

  针对分钟级别的指标统计一般咋搞的啊?直接在flink里面闭环么,还是明细宽表先写olap再基于ola

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

  starrocks，和 doris 你们选择依据是啥，为啥都选SR？

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

  StraRocks 不是apack 的开源吧，维护效率会不会较低？

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

  StraRocks 来源于 Doris？

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

  flink source impala sink hudi的cow+upsert任务一直在反复的报错

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

  flink中sp能页面启停应用吗？

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

  flink主键会一直保留在状态中吗？

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

  如果 kafka topic增加分区后 下游的flink任务不重启任务的话是会丢数据嘛？

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

  flink向kafka'写数据时候这个错误，咋整？

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

  把debezium升到了1.7报这个，是不是归档日志产生的太快了？

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

  flink官网从哪里可以进去flink-gelly相关内容？

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

  十万数据量，cep内存占用巨大，7G内存消耗大部分是DewayNumber占用的，cep逻辑很简单为

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

  FlinkSQL 消费kafka写入iceberg，报java.nio.channels.Close

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

  flink测试邮件报警报了这个错，163企业邮箱是我自己的，能够发送咋办？

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

  在dinky内启动yarn-session是dinky本来就不支持吗，还是得设置下什么？

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

  stand alone模式可以正常启动，yarn perjob 模式下，flink job 一直初始

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

  flink这个报错是任务刚开始打印出来的警告信息的错误，需要关注吗？

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

  flink这个报错是什么情况导致的嘛？这个错误会隔一段时间打印出来一次

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

  checkpoint 为啥会失败.. 这个原因怎么看？

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

  flink怎么计算前后两条数据的差值呢？比如我计算用户的登录间隔