JACKJACK_个人页

2021年12月

• 12.08 17:01:28
  回答了问题 2021-12-08 17:01:28

  flink作业版本管理实现方案探讨

  赞0 踩0 评论0
• 12.08 16:18:03
  提交了问题 2021-12-08 16:18:03

  Flink Jdbc sink写入多表如何实现

• 12.08 16:15:12
  提交了问题 2021-12-08 16:15:12

  yarn per模式如何配置rocksDB的本地目录localdir--v1.10.1

• 12.08 16:14:53
  提交了问题 2021-12-08 16:14:53

  K8s HA Session模式下1.12.1 jobmanager 周期性 restart

• 12.08 16:14:14
  提交了问题 2021-12-08 16:14:14

  flink 写hive的并行度只能为1

• 12.08 16:13:52
  提交了问题 2021-12-08 16:13:52

  flink 写hive decimal类型报错

• 12.08 16:13:28
  提交了问题 2021-12-08 16:13:28

  flink1.11.1启动问题

• 12.08 16:13:06
  提交了问题 2021-12-08 16:13:06

  flink yarn application 提交任务出错

• 12.08 16:12:44
  提交了问题 2021-12-08 16:12:44

  Pyflink 提交 Batch 任务后报错 “Failed to execute sql”

• 12.08 16:12:16
  提交了问题 2021-12-08 16:12:16

  yarn-per-job 模式 savepoint执行保存点报错

• 12.08 16:11:55
  提交了问题 2021-12-08 16:11:55

  设置状态存储位置后，job运行起来后找不到状态数据

• 12.08 16:11:27
  提交了问题 2021-12-08 16:11:27

  flink heartbeat timeout

• 12.08 16:10:59
  提交了问题 2021-12-08 16:10:59

  Flink 1.11 SQL可以支持kafka动态分区发现么？

• 12.08 16:09:49
  提交了问题 2021-12-08 16:09:49

  flink1.12.0 native k8s启动不了

• 12.08 16:09:20
  提交了问题 2021-12-08 16:09:20

  flink监控

• 12.08 15:52:37
  提交了问题 2021-12-08 15:52:37

  Flink与MySQL对接相关的问题

• 12.08 15:51:51
  提交了问题 2021-12-08 15:51:51

  Flink SQL kafka connector有办法获取到partition、offset信息嘛

• 12.08 15:51:20
  提交了问题 2021-12-08 15:51:20

  flink sql是否有json_to_map函数，或者实现方法是怎么样的？

• 12.08 15:50:15
  提交了问题 2021-12-08 15:50:15

  FlinkUserCodeClassLoader在session模式的集群下是如何卸载类的

• 12.08 15:49:21
  提交了问题 2021-12-08 15:49:21

  不同程序间checkpoint迁移

• 12.08 15:47:44
  提交了问题 2021-12-08 15:47:44

  Pyflink JVM Metaspace 内存泄漏定位

• 12.08 15:47:19
  提交了问题 2021-12-08 15:47:19

  公司强行拆分Orders主表，遇到事实表join请各位大神们支个招。

• 12.08 15:46:40
  提交了问题 2021-12-08 15:46:40

  为什么仅支持recoverableWriter

• 12.08 15:46:10
  提交了问题 2021-12-08 15:46:10

  Flink写hdfs提交任务就报错

• 12.08 15:45:44
  提交了问题 2021-12-08 15:45:44

  Flink 并行度问题

• 12.08 15:45:18
  提交了问题 2021-12-08 15:45:18

  pyflink 1.12.1 没有 python 3.8 安装文件

• 12.08 15:38:28
  提交了问题 2021-12-08 15:38:28

  Flink on yarn JDK 版本支持问题

• 12.08 15:37:35
  提交了问题 2021-12-08 15:37:35

  请教Cumulate Windows问题

• 12.08 15:37:05
  提交了问题 2021-12-08 15:37:05

  FlinkSQL1.12查询hive表很快finished？

• 12.08 15:36:38
  提交了问题 2021-12-08 15:36:38

  根据业务需求选择合适的flink state

• 12.08 11:06:54
  提交了问题 2021-12-08 11:06:54

  flink sql 执行limit 很少的语句依然会暴增

• 12.08 11:06:17
  提交了问题 2021-12-08 11:06:17

  python udf 提交到本地节点执行报错

• 12.08 11:05:49
  提交了问题 2021-12-08 11:05:49

  咨询关于flink究竟使用的是log4j1还是log4j2.

• 12.08 11:05:03
  提交了问题 2021-12-08 11:05:03

  多流join的场景如何优化

• 12.08 11:04:33
  提交了问题 2021-12-08 11:04:33

  请教关于Flink yarnship的使用

• 12.08 11:03:52
  提交了问题 2021-12-08 11:03:52

  flink启动任务时异常，加载不到flink/lib目录下的包

• 12.08 11:03:26
  提交了问题 2021-12-08 11:03:26

  flink-sql-gateway支持远程吗

• 12.08 11:02:56
  提交了问题 2021-12-08 11:02:56

  pyflink 1.11 connector数据读取问题

• 12.08 11:02:12
  提交了问题 2021-12-08 11:02:12

  Flink sql 1.12写入hive报metastore失败

• 12.08 11:01:21
  提交了问题 2021-12-08 11:01:21

  flink-sql-gateway稳定性如何，可以在生产环境使用吗？

• 12.08 11:00:45
  提交了问题 2021-12-08 11:00:45

  flink-sql-gateway相关问题

• 12.08 11:00:12
  提交了问题 2021-12-08 11:00:12

  flink-1.12.1 k8s Session集群模式没有生成Stdout输出文件

• 12.08 10:59:36
  提交了问题 2021-12-08 10:59:36

  Flink SQL csv格式分隔符设置失败怎么解决？

• 12.08 10:59:08
  提交了问题 2021-12-08 10:59:08

  flink-sql-gateway如何使用flink自定义的udf

• 12.08 10:58:34
  提交了问题 2021-12-08 10:58:34

  sql编译代码时超过64kb导致编译失败,请问有啥办法绕过这个问题吗？

• 12.08 10:58:04
  提交了问题 2021-12-08 10:58:04

  用application mode部署应用，问题如下

• 12.08 10:57:23
  提交了问题 2021-12-08 10:57:23

  Flink1.12 批处理模式，分词统计时单词个数为1的单词不会被打印怎么处理？

• 12.08 10:56:56
  提交了问题 2021-12-08 10:56:56

  我们昨天使用flink 1.12提交任务到yarn时，遇到个比较奇怪的问题

• 12.08 10:56:21
  提交了问题 2021-12-08 10:56:21

  麻烦各位老师分析下~

• 12.08 10:55:48
  提交了问题 2021-12-08 10:55:48

  怎么理解 tolerableCheckpointFailureNumber？