雪哥哥_个人页

2021年12月

• 12.07 15:28:39
  回答了问题 2021-12-07 15:28:39

  blink ha，进程启动就挂掉

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

  flink任务 动态更新（热部署） 问题请教

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

  flink 1.7.2集群异常退出

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

  flink stream 如何选择使用 broadcast还是自定义source？

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

  sql-client batch 模式执行报错

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

  如何每五分钟统计一次当天某个消息的总条数

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

  flink-kafka 消费组问题

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

  使用hdfs保存checkpoint一段时间后报错

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

  会话窗口关闭时间的问题

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

  taskmanager faild

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

  Flink 状态使用问题咨询

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

  flink并行度设置问题

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

  窗口触发机制的疑惑

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

  求助flink Buffer pool is destroyed异常

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

  flink on yarn 启动任务失败

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

  写HBase慢造成消息堆积，有没有异步IO可以用于sink或者outputFormat的方法？

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

  flink on yarn 模式 日志问题

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

  请教关于Keyed() 方法的问题。

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

  blink提交yarn卡在一直重复分配container

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

  1.7.1版本getDistributedCache().getFile("key")失败问题

  赞0 踩0 评论0
• 12.07 14:17:45
  回答了问题 2021-12-07 14:17:45

  方案询问

  赞0 踩0 评论0
• 12.07 14:17:32
  回答了问题 2021-12-07 14:17:32

  HA切换

  赞0 踩0 评论0
• 12.06 22:01:45
  提交了问题 2021-12-06 22:01:45

  flink kafka SQL Connectors 传递kerberos 参数

• 12.06 22:01:07
  提交了问题 2021-12-06 22:01:07

  Flink sql 转义字符问题

• 12.06 22:00:26
  提交了问题 2021-12-06 22:00:26

  flinksql kafka 插入mysql 的insert语法问题和唯一主键的问题

• 12.06 21:58:59
  回答了问题 2021-12-06 21:58:59

  sql中使用Create view 报错怎么办？

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

  checkpoint失败是怎么回事？

  赞0 踩0 评论0
• 12.06 21:58:23
  回答了问题 2021-12-06 21:58:23

  使用pyflink的Table api时pyflink udf函数报错怎么办？

  赞0 踩0 评论0
• 12.06 21:58:05
  回答了问题 2021-12-06 21:58:05

  Flink1.9 yarn session模式 经常Ask timed out怎么办？

  赞0 踩0 评论0
• 12.06 21:57:46
  回答了问题 2021-12-06 21:57:46

  Flink 有支持类似MR一样支持opts参数的变量替换么？

  赞0 踩0 评论0
• 12.06 21:57:17
  回答了问题 2021-12-06 21:57:17

  flink无法获取到数据输出怎么办？

  赞0 踩0 评论0
• 12.06 21:56:31
  回答了问题 2021-12-06 21:56:31

  我在pyflink中使用SQL DDL创建kafka源，总提示创建失败怎么办？

  赞0 踩0 评论0
• 12.06 21:56:09
  回答了问题 2021-12-06 21:56:09

  在yarn-session模式下怎么用rest api 触发savepoint并停止任务？

  赞0 踩0 评论0
• 12.06 21:54:00
  回答了问题 2021-12-06 21:54:00

  flink数据sink到mysql 是事务处理怎么解决？

  赞0 踩0 评论0
• 12.06 21:53:37
  回答了问题 2021-12-06 21:53:37

  flink sql 窗口使用了处理时间滚动窗口方式 但是都是只有5分结束的时候才能把聚合结果输出

  赞0 踩0 评论0
• 12.06 21:53:07
  回答了问题 2021-12-06 21:53:07

  消费kafka时，是如何实时查看kafka topic的挤压量的？

  赞0 踩0 评论0
• 12.06 21:52:50
  回答了问题 2021-12-06 21:52:50

  pyflink 嵌套使用函数出错怎么解决？

  赞0 踩0 评论0
• 12.06 21:52:29
  回答了问题 2021-12-06 21:52:29

  flink sql upsert模式写入mysql，es等key一定是groupby之后所有字段吗？

  赞0 踩0 评论0
• 12.06 21:52:09
  回答了问题 2021-12-06 21:52:09

  flink1.10整合hbase测试一直报错怎么办？

  赞0 踩0 评论0
• 12.06 21:51:50
  回答了问题 2021-12-06 21:51:50

  没有设置 chk的存储数默认是多保留多少份呢？

  赞0 踩0 评论0
• 12.06 21:51:29
  回答了问题 2021-12-06 21:51:29

  想用flink1.10整合hbase，请问一下hadoop，hbase都需要什么版本？

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

  Flink SQL create table 关键字 table 加反引号 解析失败怎么办？

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

  Flink SQL create table 关键字 table 加反引号 解析失败是什么情况？

  赞0 踩0 评论0
• 12.06 21:50:19
  回答了问题 2021-12-06 21:50:19

  关于flinksql与mysql维表关联 关于mysql更新的问题 有没有好的方法？

  赞0 踩0 评论0
• 12.06 21:49:52
  回答了问题 2021-12-06 21:49:52

  如果我放在open 中的规则 有可能发生改变,需要重新更新的话呢?

  赞0 踩0 评论0
• 12.06 21:49:34
  回答了问题 2021-12-06 21:49:34

  flink1.9 Sql 注册的中间临时表不自动存state的吗？

  赞0 踩0 评论0
• 12.06 21:49:16
  回答了问题 2021-12-06 21:49:16

  flink 1.9 自定义UDAF 实现state管理的逻辑吗？

  赞0 踩0 评论0
• 12.06 21:48:56
  回答了问题 2021-12-06 21:48:56

  job已经跑起来了，但是flink的ui页面卡住了是什么原因？

  赞0 踩0 评论0
• 12.06 21:48:34
  回答了问题 2021-12-06 21:48:34

  flink sql 通过计算列提取字段定义watermark后窗口计算没有结果输出怎么办？

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

  flink sink to mysql 是推荐 继承RichSinkFunction的方式吗

  赞0 踩0 评论0