雪哥哥_个人页

2021年12月

• 12.06 16:02:18
  回答了问题 2021-12-06 16:02:18

  Flink 1.11里如何parse出未解析的执行计划

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

  flink sql 写入hive问题

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

  求教，如果想要从flinksql中提取出列级别的血缘关系，请问有什么好的方案吗

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

  Flink-1.11.1 Rest API使用

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

  pyflink和pyspark中引用包不兼容

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

  pyflink和flink版本的兼容性问题

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

  Flink 读取 Kafka 多个 Partition 问题，如何解决

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

  使用Flink Table API & SQL编写流应用，SQL中的NOW()等时间函数如何理解？

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

  Flink1.10 history server无法监控 FlinkSQL任务

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

  FlinkSQL 窗口内排序使用方法疑问

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

  请教 table /sql API, 窗口frist/last value

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

  StreamSQL 进行窗口计算的疑问

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

  window和timeWindow的区别

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

  请问flink1.11版本如何设置checkpoint的默认保存个数

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

  提交pyflink作业到YARN集群报错

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

  Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题

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

  flinksql指定kafka多topic

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

  pyflink 如何正确设置高速度？（如何提速）

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

  Flink 1.11 SQL作业中调用UDTF 出现问题

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

  容忍checkpoint 失败次数和重启策略冲突吗

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

  flink sql 客户端连接hive 3.1.0出现connection refused异常

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

  Flink-kafka-connector Consumer配置警告，为何会报如此警告呢？

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

  请问，如果我要保证端到端的精准一次性?

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

  flink如何从流中取出自定义的数据结构并赋值给变量？

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

  Flink撤回机制不起作用，如何解决？

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

  flink流、批场景下kafka拉取速率问题：每批次拉取多少条？

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

  flink sql 不支持 mysql cdc 以 canal json 格式发到kafka吗？

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

  flink -conf.yaml修改的问题

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

  flink消费kafka数据open()方法初始换多次的问题

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

  Flink 1.12.2 sql api 使用parquet格式报错

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

  flink集群提交任务挂掉，需要特别的配置吗？

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

  现在的flink1.12支持批流混合的作业吗？

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

  TUMBLE函数不支持 回撤流，如何解决？

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

  把Flink连接Kafka封装成通用的方法？

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

  通过算子的构造方法传递变量失效，如何解决？

  赞0 踩0 评论0
• 12.05 13:01:57
  回答了问题 2021-12-05 13:01:57

  flink1.11版本 -C 指令并未上传udf jar包，求指教

  赞0 踩0 评论0
• 12.05 13:01:02
  回答了问题 2021-12-05 13:01:02

  設置look up table source的一些问题

  赞0 踩0 评论0
• 12.05 12:59:41
  回答了问题 2021-12-05 12:59:41

  flink sql cdc发到kafka消息表名信息缺失问题

  赞0 踩0 评论0
• 12.05 12:59:13
  回答了问题 2021-12-05 12:59:13

  Flinkjob消费kafka 失败，无法拿到offset值,如何解决

  赞0 踩0 评论0
• 12.05 12:58:51
  回答了问题 2021-12-05 12:58:51

  Flink job消费kafka 失败，无法拿到offset值，请指教

  赞0 踩0 评论0
• 12.05 12:57:56
  回答了问题 2021-12-05 12:57:56

  Flink SQL Metrics中Kafka Offset请教

  赞0 踩0 评论0
• 12.05 12:55:54
  回答了问题 2021-12-05 12:55:54

  DataStreamAPI 与flink sql疑问

  赞0 踩0 评论0
• 12.05 12:54:04
  提交了问题 2021-12-05 12:54:04

  Flink反压定位算子，如何解决？

• 12.05 12:52:58
  提交了问题 2021-12-05 12:52:58

  咨询JM磁盘磁盘打满问题

• 12.05 12:52:32
  提交了问题 2021-12-05 12:52:32

  Flink Jdbc sink写入多表如何实现？

• 12.05 12:52:04
  提交了问题 2021-12-05 12:52:04

  flink-cdc-mysql 使用时遇到的问题，求解答

• 12.05 12:51:34
  提交了问题 2021-12-05 12:51:34

  flink mysql cdc + hive streaming疑问

• 12.05 12:51:09
  提交了问题 2021-12-05 12:51:09

  minibatch+状态ttl设置不生效问题如何优化？