小阿矿_个人页

2021年12月

• 12.07 11:42:48
  提交了问题 2021-12-07 11:42:48

  UDTAGGs sql的查询怎么写

• 12.07 11:41:15
  回答了问题 2021-12-07 11:41:15

  flink 1.11 ddl 写mysql的问题

  赞0 踩0 评论0
• 12.07 11:40:55
  回答了问题 2021-12-07 11:40:55

  flink 1.11 cdc相关问题

  赞0 踩0 评论0
• 12.07 11:40:40
  回答了问题 2021-12-07 11:40:40

  flink1.11查询结果每秒入库到mysql数量很少

  赞0 踩0 评论0
• 12.07 11:39:24
  回答了问题 2021-12-07 11:39:24

  https://developer.aliyun.com/ask/371504

  赞0 踩0 评论0
• 12.07 11:38:50
  回答了问题 2021-12-07 11:38:50

  Apache Flink常见问题汇总【精品问答】

  赞0 踩0 评论0
• 12.07 11:38:36
  回答了问题 2021-12-07 11:38:36

  flink sql 读取mysql

  赞0 踩0 评论0
• 12.07 11:38:23
  回答了问题 2021-12-07 11:38:23

  Flink CPU利用率低

  赞0 踩0 评论0
• 12.07 11:37:54
  回答了问题 2021-12-07 11:37:54

  【flink sql】flink sql insert into插入语句的问题

  赞0 踩0 评论0
• 12.07 11:37:37
  回答了问题 2021-12-07 11:37:37

  flink 聚合 job 重启问题

  赞0 踩0 评论0
• 12.07 11:37:20
  回答了问题 2021-12-07 11:37:20

  Could not find any factory for identifier 'kafka'

  赞0 踩0 评论0
• 12.07 11:36:05
  回答了问题 2021-12-07 11:36:05

  Blink的Batch模式的并行度问题

  赞0 踩0 评论0
• 12.07 11:35:52
  回答了问题 2021-12-07 11:35:52

  kafka-connect json格式适配问题？

  赞0 踩0 评论0
• 12.07 11:35:39
  回答了问题 2021-12-07 11:35:39

  flink1.11.0 执行sqlQuery时报NullPointException

  赞0 踩0 评论0
• 12.07 11:35:25
  回答了问题 2021-12-07 11:35:25

  Flink SQL 解析复杂（嵌套）JSON的问题 以及写入到hive类型映射问题

  赞0 踩0 评论0
• 12.07 11:35:03
  回答了问题 2021-12-07 11:35:03

  flink-1.11 hive-1.2.1 ddl 无法写入数据

  赞0 踩0 评论0
• 12.07 11:34:38
  回答了问题 2021-12-07 11:34:38

  flink on yarn 读取 hbase数据时 ，Task失败，具体描述如下

  赞0 踩0 评论0
• 12.07 11:34:01
  回答了问题 2021-12-07 11:34:01

  flink1.11 sql 发布到yarn session时找不到hbase相关的类

  赞0 踩0 评论0
• 12.07 11:33:48
  回答了问题 2021-12-07 11:33:48

  flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗

  赞0 踩0 评论0
• 12.07 11:33:33
  回答了问题 2021-12-07 11:33:33

  关于window过程中barrier的问题

  赞0 踩0 评论1
• 12.07 11:31:55
  回答了问题 2021-12-07 11:31:55

  StatementSet 里添加多个insertsql执行

  赞0 踩0 评论0
• 12.07 11:31:43
  回答了问题 2021-12-07 11:31:43

  flink消费kafka提交偏移量

  赞0 踩0 评论0
• 12.07 11:31:28
  回答了问题 2021-12-07 11:31:28

  flink 1.11 rest api saveppoint接口 异常

  赞0 踩0 评论0
• 12.07 11:29:41
  回答了问题 2021-12-07 11:29:41

  flink1.9.1 在WebUI中查看committedOffsets指标为负值

  赞0 踩0 评论0
• 12.07 11:29:13
  回答了问题 2021-12-07 11:29:13

  [DISCUSS] FLIP-133: Rework PyFlink Documentation

  赞0 踩0 评论0
• 12.07 11:28:44
  回答了问题 2021-12-07 11:28:44

  flink1.10.1/1.11.1 使用sql 进行group 和 时间窗口 操作后 状态越来越大

  赞0 踩0 评论0
• 12.07 11:28:20
  回答了问题 2021-12-07 11:28:20

  RocksDBKeyedStateBackend如何写磁盘

  赞0 踩0 评论0
• 12.07 11:27:57
  回答了问题 2021-12-07 11:27:57

  Flink 1.11 submit job timed out

  赞0 踩0 评论0
• 12.07 11:27:41
  回答了问题 2021-12-07 11:27:41

  pyflink的where该如何使用？如何筛选？

  赞0 踩0 评论0
• 12.07 11:27:05
  回答了问题 2021-12-07 11:27:05

  flink 1.11.2 keyby 更换partition

  赞0 踩0 评论0
• 12.07 11:26:40
  回答了问题 2021-12-07 11:26:40

  Flink中是否可动态Task调度

  赞0 踩0 评论0
• 12.07 11:26:40
  回答了问题 2021-12-07 11:26:40

  Flink中是否可动态Task调度

  赞0 踩0 评论0
• 12.07 11:25:53
  回答了问题 2021-12-07 11:25:53

  yarn部署模式kerberos问题

  赞0 踩0 评论0
• 12.07 11:25:41
  回答了问题 2021-12-07 11:25:41

  FlinkSLQ双流join使用LAST_VALUE + INTERVAL JOIN时遇到问题

  赞0 踩0 评论0
• 12.07 11:25:26
  回答了问题 2021-12-07 11:25:26

  使用BroadcastStream后checkpoint失效

  赞0 踩0 评论0
• 12.07 11:24:57
  回答了问题 2021-12-07 11:24:57

  kafka table connector eventTime的问题

  赞0 踩0 评论0
• 12.07 11:24:42
  回答了问题 2021-12-07 11:24:42

  提交flink sql任务报错

  赞0 踩0 评论0
• 12.07 11:24:25
  回答了问题 2021-12-07 11:24:25

  1.11.1 报OutOfMemoryError: Metaspace. 错误

  赞0 踩0 评论0
• 12.07 11:24:11
  回答了问题 2021-12-07 11:24:11

  flink 1.11.1 web ui 页面查看source算子的detail数据，recoreds

  赞0 踩0 评论0
• 12.07 11:23:56
  回答了问题 2021-12-07 11:23:56

  flink1.11.0 sql自定义UDAF包含复合类型时报Incompatible types

  赞0 踩0 评论0
• 12.07 11:23:24
  回答了问题 2021-12-07 11:23:24

  使用flink-CDC checkpoint超时问题

  赞0 踩0 评论0
• 12.07 11:22:52
  回答了问题 2021-12-07 11:22:52

  cdc代码报错

  赞0 踩0 评论0
• 12.07 11:22:33
  回答了问题 2021-12-07 11:22:33

  flink 1.11.2 cep rocksdb 性能调优

  赞0 踩0 评论0
• 12.07 11:22:10
  回答了问题 2021-12-07 11:22:10

  flink-1.11 写 hive 报错

  赞0 踩0 评论0
• 12.06 16:55:31
  提交了问题 2021-12-06 16:55:31

  flink row 类型

• 12.06 16:55:07
  提交了问题 2021-12-06 16:55:07

  flink sql 1.11 kafka source with子句使用新参数，下游消费不到数据

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

  flink1.11 tablefunction

• 12.06 16:54:10
  提交了问题 2021-12-06 16:54:10

  flink1.11 web ui没有DAG

• 12.06 16:53:47
  提交了问题 2021-12-06 16:53:47

  flink stream如何为每条数据生成自增主键

• 12.06 16:53:23
  提交了问题 2021-12-06 16:53:23

  flink 1.9.2 升级 1.10.0 任务失败不能从checkpoint恢复