小阿矿_个人页

2021年12月

• 12.06 15:45:55
  提交了问题 2021-12-06 15:45:55

  flink 1.11运算结果存mysql出错

• 12.06 15:45:30
  提交了问题 2021-12-06 15:45:30

  flink on yarn日志问题

• 12.06 15:44:56
  提交了问题 2021-12-06 15:44:56

  [flink-sql] 如何在sql运行时动态修改kafka的scan.startup.mode

• 12.06 15:44:04
  提交了问题 2021-12-06 15:44:04

  flink-1.11使用executeSql()执行DDL语句问题

• 12.06 15:43:40
  提交了问题 2021-12-06 15:43:40

  flink-benchmarks使用求助

• 12.06 15:33:55
  提交了问题 2021-12-06 15:33:55

  代码中如何取消正在运行的Flink Streaming作业

• 12.06 15:32:19
  提交了问题 2021-12-06 15:32:19

  State 0点清除的问题

• 12.06 15:31:53
  提交了问题 2021-12-06 15:31:53

  flink1.9状态及作业迁移

• 12.06 15:31:32
  提交了问题 2021-12-06 15:31:32

  Flink SQL处理Array型的JSON

• 12.06 15:31:07
  提交了问题 2021-12-06 15:31:07

  flink 同时sink hbase和hive，hbase少记录

• 12.06 15:30:45
  提交了问题 2021-12-06 15:30:45

  【Flink Join内存问题】

• 12.06 15:30:23
  提交了问题 2021-12-06 15:30:23

  flink 1.11 createTemporaryTable 指定 rowtime 字段报 Fie

• 12.06 15:30:01
  提交了问题 2021-12-06 15:30:01

  单流的一条数据，需要先sink 至mysql，再sink至kafka，并保证两sink的原子性以及s

• 12.06 15:29:38
  提交了问题 2021-12-06 15:29:38

  flink sql报错 Could not find any factory for identif

• 12.06 15:29:16
  提交了问题 2021-12-06 15:29:16

  使用Flink Array Field Type

• 12.06 15:28:54
  提交了问题 2021-12-06 15:28:54

  flink 1.11 es未定义pk的sink问题

• 12.06 15:28:31
  提交了问题 2021-12-06 15:28:31

  Table options do not contain an option key 'connec

• 12.06 15:28:04
  提交了问题 2021-12-06 15:28:04

  flink使用debezium-json format报错

• 12.06 15:27:36
  提交了问题 2021-12-06 15:27:36

  flink1.10.1 flink sql消费kafka当parallelism大于1时不产生wat

• 12.06 15:27:14
  提交了问题 2021-12-06 15:27:14

  flink sql 侧输出

• 12.06 15:26:49
  提交了问题 2021-12-06 15:26:49

  flink 1.11 sql作业提交JM报错

• 12.06 15:26:23
  提交了问题 2021-12-06 15:26:23

  flink 1.11 local execution oom问题

• 12.06 15:25:59
  提交了问题 2021-12-06 15:25:59

  flink1.10.1在yarn上无法写入kafka的问题

• 12.06 15:25:35
  提交了问题 2021-12-06 15:25:35

  一个source多个sink的同步问题

• 12.06 15:25:11
  提交了问题 2021-12-06 15:25:11

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

• 12.06 15:24:40
  提交了问题 2021-12-06 15:24:40

  flink-state问题

• 12.06 15:24:15
  提交了问题 2021-12-06 15:24:15

  flink kafka connector中获取kafka元数据

• 12.06 15:23:52
  提交了问题 2021-12-06 15:23:52

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

• 12.06 15:23:26
  提交了问题 2021-12-06 15:23:26

  DataStream的state问题

• 12.06 15:21:48
  提交了问题 2021-12-06 15:21:48

  关于jdbc connector扩展问题

• 12.06 15:21:22
  提交了问题 2021-12-06 15:21:22

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

• 12.06 15:20:50
  提交了问题 2021-12-06 15:20:50

  flink sql子查询状态清理不掉

• 12.06 15:20:28
  提交了问题 2021-12-06 15:20:28

  Flink状态调试

• 12.06 15:20:06
  提交了问题 2021-12-06 15:20:06

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

• 12.06 15:19:44
  提交了问题 2021-12-06 15:19:44

  Flink SQL 关键字 user？

• 12.06 15:19:16
  提交了问题 2021-12-06 15:19:16

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

• 12.06 15:18:48
  提交了问题 2021-12-06 15:18:48

  【Flink的shuffle mode】

• 12.06 15:18:23
  提交了问题 2021-12-06 15:18:23

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

• 12.06 15:17:56
  提交了问题 2021-12-06 15:17:56

  flink1.9读取阿里Mq问题

• 12.06 15:17:33
  提交了问题 2021-12-06 15:17:33

  table execution-options 能否通过 -yd 生效

• 12.06 15:17:05
  提交了问题 2021-12-06 15:17:05

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

• 12.06 15:16:35
  提交了问题 2021-12-06 15:16:35

  rocksdb的block cache usage应该如何使用

• 12.06 15:16:13
  提交了问题 2021-12-06 15:16:13

  kafkaf To mysql 写入问题

• 12.06 15:14:42
  提交了问题 2021-12-06 15:14:42

  flink job 跑一段时间 watermark 不推进的问题

• 12.06 15:12:56
  提交了问题 2021-12-06 15:12:56

  flink1.11 Application 模式下启动失败问题

• 12.06 15:12:28
  提交了问题 2021-12-06 15:12:28

  flink sqlUpdate,如何获取里面的字段，字段类型，with 等3个属性

• 12.06 15:11:41
  提交了问题 2021-12-06 15:11:41

  flink 1.11 executeSql查询kafka表print没有输出

• 12.06 14:14:27
  回答了问题 2021-12-06 14:14:27

  FlinkSQL导致Prometheus内存暴涨

  赞0 踩0 评论0
• 12.06 14:14:03
  回答了问题 2021-12-06 14:14:03

  flink-json 函数用法

  赞0 踩0 评论0
• 12.06 14:13:41
  回答了问题 2021-12-06 14:13:41

  Flink SQL 是否存在类似MySQL的group_concat函数

  赞0 踩0 评论0