小阿矿_个人页

2021年12月

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

  FLINK SQL 消费kafka消息乱序问题

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

  flink 1.11.2 cdc: cdc sql 结果表的sink顺序问题， 不同并行度下从sav

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

  flink1.11编译失败是什么原因

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

  canal-json 分库分表场景应用有什么思路吗？

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

  flink on native k8s

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

  flink sql cdc 如果只处理一次全量数据问题

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

  flink sql实时计算分位数如何实现

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

  发现flinksql写hive比写hdfs慢很多

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

  udtf collect方法 报NEP

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

  flink1.11.2 一直不入hbase问题

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

  Flink CDC 遇到关于不发生packet造成的卡顿问题该如何解决

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

  flink sql 连接mysql 无数据输出

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

  flink 1.11.2 rowtime和proctime流 Interval Join 问题错误问

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

  slot问题

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

  flink sql时间戳字段类型转换问题

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

  用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确

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

  Flink SQL Row里嵌套Array<Row>该如何用DDL定义?

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

  SQL Cli中找不到DeserializationSchemaFactory

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

  flink使用hive udf函数会报错

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

  flink-1.11.2提交到yarn一直处于CREATED中

  赞0 踩0 评论0
• 12.03 16:54:11
  提交了问题 2021-12-03 16:54:11

  ProcessingTime下的watermark

• 12.03 16:53:48
  提交了问题 2021-12-03 16:53:48

  关于Catalog的建议

• 12.03 16:53:24
  提交了问题 2021-12-03 16:53:24

  Flink SQL 对延迟数据怎么处理？

• 12.03 16:52:04
  提交了问题 2021-12-03 16:52:04

  关于flink实时写入hbase用flush方法频繁报操作超时问题

• 12.03 16:51:39
  提交了问题 2021-12-03 16:51:39

  flink sql 中是否可以使用 mysql 的存储过程和函数？

• 12.03 16:51:16
  提交了问题 2021-12-03 16:51:16

  flink读mysql分库分表

• 12.03 16:50:53
  提交了问题 2021-12-03 16:50:53

  JdbcUpsertTableSink输出的时候报‘Duplicate entry’问题

• 12.03 16:46:08
  提交了问题 2021-12-03 16:46:08

  pyflink 1.11.1 调用包含第三方依赖库的udf时报错

• 12.03 16:45:47
  提交了问题 2021-12-03 16:45:47

  FlinkSQL CDC 窗口分组聚合求助

• 12.03 16:45:26
  提交了问题 2021-12-03 16:45:26

  TUMBLE函数不支持 回撤流

• 12.03 16:45:00
  提交了问题 2021-12-03 16:45:00

  求助：Flink DataStream 的 windowoperator 后面apply 方法不执行

• 12.03 16:44:34
  提交了问题 2021-12-03 16:44:34

  Flink 1.10 和 Flink 1.11 中 keyBy 算子聚合多个字段的问题

• 12.03 16:43:26
  提交了问题 2021-12-03 16:43:26

  flink zeppelin的type参数(append/update/single)和flink的

• 12.03 16:42:10
  提交了问题 2021-12-03 16:42:10

  Flink cdc 多表关联处理延迟很大

• 12.03 16:34:19
  提交了问题 2021-12-03 16:34:19

  pyflink1.11 window groupby出错

• 12.03 16:33:54
  提交了问题 2021-12-03 16:33:54

  flink1.11 TableEnvironment 不支持注册 Aggregate Functio

• 12.03 16:33:28
  提交了问题 2021-12-03 16:33:28

  Flink JSON反序列化DECIMAL精度丢失

• 12.03 16:32:36
  提交了问题 2021-12-03 16:32:36

  flink keyedState 能不能存储泛型或抽象类型

• 12.03 16:31:16
  提交了问题 2021-12-03 16:31:16

  flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert

• 12.03 16:26:58
  提交了问题 2021-12-03 16:26:58

  使用flink1.11.1的debezium-changelog目前是否不支持Watermark

• 12.03 16:25:35
  提交了问题 2021-12-03 16:25:35

  Flink未来会弃用TableSourceFactory吗

• 12.03 16:25:11
  提交了问题 2021-12-03 16:25:11

  zookeeper更换leader对flink的影响

• 12.03 16:24:50
  提交了问题 2021-12-03 16:24:50

  flink-1.11.2 的 内存溢出问题

• 12.03 16:24:25
  提交了问题 2021-12-03 16:24:25

  native K8s模式下，pod系统占用内存

• 12.03 16:24:05
  提交了问题 2021-12-03 16:24:05

  Blink 1.11 create view是不是没有办法把rowtime带下去？

• 12.03 16:23:32
  提交了问题 2021-12-03 16:23:32

  Flink sql 无法用!=

• 12.03 16:23:01
  提交了问题 2021-12-03 16:23:01

  flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象

• 12.03 16:22:38
  提交了问题 2021-12-03 16:22:38

  flink算子类在多个subtask中是各自初始化1个实例对象吗？

• 12.03 16:22:11
  提交了问题 2021-12-03 16:22:11

  flink 1.11.2 如何配置时区

• 12.03 16:21:47
  提交了问题 2021-12-03 16:21:47

  flink1.11 sql ddl 连接kafka读取数据，使用事件时间窗口，无法触发，相同的sql