小阿矿_个人页

2021年12月

• 12.08 10:56:29
  提交了问题 2021-12-08 10:56:29

  在 Trigger 里可以知道 Window 中数据的状况吗

• 12.08 10:56:09
  提交了问题 2021-12-08 10:56:09

  Flink-1.9.1

• 12.08 10:55:41
  提交了问题 2021-12-08 10:55:41

  如何让Flink trigger只输出有变化的数据？

• 12.08 10:55:22
  提交了问题 2021-12-08 10:55:22

  flink SQL UpsertTable 语义问题

• 12.08 10:54:49
  提交了问题 2021-12-08 10:54:49

  Checkpoint failed all the time

• 12.07 16:02:50
  提交了问题 2021-12-07 16:02:50

  flink sql连接HBase报错

• 12.07 16:01:57
  提交了问题 2021-12-07 16:01:57

  作业从flink1.9.0迁移到1.10.1

• 12.07 16:01:35
  提交了问题 2021-12-07 16:01:35

  pyflink udf中发送rest api会导致udf被调用两次

• 12.07 15:56:31
  提交了问题 2021-12-07 15:56:31

  flink1.10升级到flink1.11 提交到yarn失败

• 12.07 15:37:38
  提交了问题 2021-12-07 15:37:38

  Flink DataStream 统计UV问题

• 12.07 15:37:18
  提交了问题 2021-12-07 15:37:18

  flink时间窗口

• 12.07 15:36:36
  提交了问题 2021-12-07 15:36:36

  kafka connector问题

• 12.07 15:36:06
  提交了问题 2021-12-07 15:36:06

  ddl es 报错

• 12.07 15:35:40
  提交了问题 2021-12-07 15:35:40

  DataStream统计uv问题

• 12.07 15:35:09
  提交了问题 2021-12-07 15:35:09

  Flink SQL如何将多个表的查询结果(列不同)聚合成一张表

• 12.07 15:34:24
  提交了问题 2021-12-07 15:34:24

  一个source多个sink的同步问题

• 12.07 15:32:49
  提交了问题 2021-12-07 15:32:49

  Flink SQL复杂JSON解析

• 12.07 15:31:37
  提交了问题 2021-12-07 15:31:37

  State里面用guava Cache

• 12.07 15:27:38
  提交了问题 2021-12-07 15:27:38

  如何在Flink SQL中使用周期性水印?

• 12.07 15:26:48
  提交了问题 2021-12-07 15:26:48

  flink 1.11 on kubernetes 构建失败

• 12.07 15:26:22
  提交了问题 2021-12-07 15:26:22

  如何在窗口关闭的时候清除状态

• 12.07 15:24:42
  提交了问题 2021-12-07 15:24:42

  flink 1.11 中cdc功能中，使用flink sql来操作一个kafka topic中的多张

• 12.07 15:24:16
  提交了问题 2021-12-07 15:24:16

  flink 1.11 connector jdbc 依赖解析失败

• 12.07 15:23:56
  提交了问题 2021-12-07 15:23:56

  求助：FLINKSQL1.10实时统计累计UV

• 12.07 15:23:23
  提交了问题 2021-12-07 15:23:23

  flink 1.11 作业执行异常

• 12.07 15:22:56
  提交了问题 2021-12-07 15:22:56

  FlinkKafkaProducer没有写入多个topic的功能

• 12.07 15:22:28
  提交了问题 2021-12-07 15:22:28

  flink 1.10.1 入 hive 格式为parquet

• 12.07 15:22:06
  提交了问题 2021-12-07 15:22:06

  作业升级到flink1.11，idea运行失败

• 12.07 15:21:31
  提交了问题 2021-12-07 15:21:31

  嵌套 json 中string 数组的解析异常

• 12.07 15:21:07
  提交了问题 2021-12-07 15:21:07

  【Flink的shuffle mode】

• 12.07 15:20:35
  提交了问题 2021-12-07 15:20:35

  Flink 1.11 SQL作业中调用UDTF 出现“No match found for func

• 12.07 15:19:04
  提交了问题 2021-12-07 15:19:04

  flink sql 读写写kafka表的时候可以指定消息的key吗

• 12.07 15:18:36
  提交了问题 2021-12-07 15:18:36

  DataStream的state问题

• 12.07 15:18:15
  提交了问题 2021-12-07 15:18:15

  关于jdbc connector扩展问题

• 12.07 15:17:55
  提交了问题 2021-12-07 15:17:55

  Flink从SavePoint启动任务，修改的代码不生效

• 12.07 15:17:27
  提交了问题 2021-12-07 15:17:27

  Flink状态调试

• 12.07 15:17:08
  提交了问题 2021-12-07 15:17:08

  Flink sql 主动使数据延时一段时间有什么方案

• 12.07 15:16:47
  提交了问题 2021-12-07 15:16:47

  Flink SQL 关键字 user？

• 12.07 15:16:24
  提交了问题 2021-12-07 15:16:24

  flink1.10 定义表时，把json数组声明成STRING类型的，查询出来是空

• 12.07 15:12:50
  提交了问题 2021-12-07 15:12:50

  flink1.10在通过TableFunction实现行转列时，Row一直是空

• 12.07 14:12:35
  提交了问题 2021-12-07 14:12:35

  作业因为异常restart后，频繁OOM

• 12.07 11:47:26
  提交了问题 2021-12-07 11:47:26

  Flink job不定期就会重启，版本是1.9

• 12.07 11:47:05
  提交了问题 2021-12-07 11:47:05

  flink1.9读取阿里Mq问题

• 12.07 11:46:45
  提交了问题 2021-12-07 11:46:45

  flink 1.10 kafka collector topic 配置pattern

• 12.07 11:45:56
  提交了问题 2021-12-07 11:45:56

  kafkaf To mysql 写入问题

• 12.07 11:45:37
  提交了问题 2021-12-07 11:45:37

  rocksdb的block cache usage应该如何使用

• 12.07 11:45:16
  提交了问题 2021-12-07 11:45:16

  flink对task分配slot问题

• 12.07 11:44:57
  提交了问题 2021-12-07 11:44:57

  做实时数仓，sql怎么保证分topic区有序

• 12.07 11:44:27
  提交了问题 2021-12-07 11:44:27

  flink任务提交方式

• 12.07 11:44:09
  提交了问题 2021-12-07 11:44:09

  flink的state过期设置