solitude._个人页

2023年03月

• 03.07 13:50:56
  提交了问题 2023-03-07 13:50:56

  flink13 checkpoint进度卡住不动，导致超时，可以从哪里进行排查呢？

• 03.07 13:50:13
  提交了问题 2023-03-07 13:50:13

  请问下一个并行度占用1核吗？我并行度设置的是10，solt为5，在yarn上看，核数是11。

• 03.07 13:49:36
  提交了问题 2023-03-07 13:49:36

  rocketmq-flink ，支持flink sql 方式写rocketmq时这个连接器怎么用呢？

• 03.07 13:48:33
  提交了问题 2023-03-07 13:48:33

  设置rocksdb之后，checkpoint应该是增量了吗？

• 03.07 13:47:54
  提交了问题 2023-03-07 13:47:54

  这里checkpoint超时是为什么呢？

• 03.07 13:47:04
  提交了问题 2023-03-07 13:47:04

  Flink CDC在支持 AWS的5.7.mysql_aurora.2.10.2 版本吗？

• 03.07 13:45:49
  提交了问题 2023-03-07 13:45:49

  下面问题怎么处理呢？

• 03.07 13:44:57
  提交了问题 2023-03-07 13:44:57

  目前任务运行在yarn上，如果调整了flink的并行度，需要手动重启，有什么解决办法吗？

• 03.07 13:44:21
  提交了问题 2023-03-07 13:44:21

  在flink中的log4j2中怎么添加mdc日志啊？

• 03.07 13:43:11
  提交了问题 2023-03-07 13:43:11

  全局并行度3，执行sql只能1是吗？

• 03.07 13:42:27
  提交了问题 2023-03-07 13:42:27

  代码只有一次,但是同一条数据用了两次udf函数是为什么？

• 03.07 13:41:42
  提交了问题 2023-03-07 13:41:42

  web-ui 加载会非常慢是什么原因呢？

• 03.07 13:40:19
  提交了问题 2023-03-07 13:40:19

  如果用dataStream 怎么反序列化 avro的数据呀？

• 03.07 13:39:46
  提交了问题 2023-03-07 13:39:46

  通过flink sql 消费这个avro后的数据改了半天 又报了这个错误是什么原因啊？

• 03.07 13:38:56
  提交了问题 2023-03-07 13:38:56

  这种情况是什么原因啊？

• 03.07 13:37:49
  提交了问题 2023-03-07 13:37:49

  这个用flink sql 读取也是报错是为什么？

• 03.07 13:37:08
  提交了问题 2023-03-07 13:37:08

  我的richmap有600个并发度，如果同时访问hive，hive能撑住吗？

• 03.07 13:36:02
  提交了问题 2023-03-07 13:36:02

  flink 消费Kafka的数据乱码，怎么解决？

• 03.07 13:35:17
  提交了问题 2023-03-07 13:35:17

  一直重启，是线程崩了吗？

• 03.07 13:34:06
  提交了问题 2023-03-07 13:34:06

  这种写入最后需要做什么结尾吗？

• 03.07 13:33:16
  提交了问题 2023-03-07 13:33:16

  报这种错误怎么解决啊？

• 03.07 13:32:30
  提交了问题 2023-03-07 13:32:30

  流式flink任务失败后，日志怎么找呢？

• 03.07 13:27:14
  提交了问题 2023-03-07 13:27:14

  对于checkpoint 跑几天就会checkpoint超时过期这种怎么排查啊？

• 03.07 13:26:25
  提交了问题 2023-03-07 13:26:25

  把flink日志发送到kafka怎么实现啊？

• 03.07 13:25:48
  提交了问题 2023-03-07 13:25:48

  下面的情况怎么处理呢？

• 03.07 13:20:14
  提交了问题 2023-03-07 13:20:14

  sqlclient 打印全部异常的 set 命令是什么？

• 03.07 13:19:39
  提交了问题 2023-03-07 13:19:39

  Java 的Integer 怎么转成 scala 的 Int类型呢？

• 03.07 13:18:34
  提交了问题 2023-03-07 13:18:34

  taskmanager.memory.flink.size不是节点分配内存吗？

• 03.07 13:17:34
  提交了问题 2023-03-07 13:17:34

  配置 state.backend: rocksdb 导致节点oom怎么处理？

• 03.07 13:16:55
  提交了问题 2023-03-07 13:16:55

  下面这种情况是为什么啊？

• 03.07 13:15:14
  提交了问题 2023-03-07 13:15:14

  数据写入HDFS 我想指定压缩格式，不想指定存储格式 可以吗 ？

• 03.07 13:14:24
  提交了问题 2023-03-07 13:14:24

  flinksql里面有禁用局部chain的配置吗?

• 03.07 13:12:37
  提交了问题 2023-03-07 13:12:37

  请问下flinkcdc能不能从指定时间开始同步数据？

• 03.07 13:11:35
  提交了问题 2023-03-07 13:11:35

  一个状态，设置了ttl, 过期时间是5分钟，如果checkpoint的时间超过5分钟，会丟数据吗？

• 03.07 13:10:42
  提交了问题 2023-03-07 13:10:42

  'scan.startup.mode' = 'latest-offset'设置成这个，消费组还有用吗

• 03.07 13:09:35
  提交了问题 2023-03-07 13:09:35

  checkpoint保存kafka offset吗？

• 03.07 13:08:50
  提交了问题 2023-03-07 13:08:50

  除了kafka，flink 可以将数据写到 RabbitMQ吗？FLINK SQL模式

• 03.07 13:07:43
  提交了问题 2023-03-07 13:07:43

  这种情况怎么处理啊？

• 03.07 13:06:21
  提交了问题 2023-03-07 13:06:21

  做checkpoint的时候内存没怎么变 ，cpu高了一点是为什么？

• 03.07 13:03:02
  提交了问题 2023-03-07 13:03:02

  checkpoint是存在job里面的?还是说只是管理checkpoint的启动呢？

• 03.07 12:15:04
  提交了问题 2023-03-07 12:15:04

  这种是不是要加配置了啊？

• 03.07 12:11:16
  提交了问题 2023-03-07 12:11:16

  为什么只用一个路径有时候找不到某个表的chk了？

2023年02月

• 02.21 18:29:00
  提交了问题 2023-02-21 18:29:00

  dataworks绑定maxcompute时报这个错误，是什么原因？

• 02.21 18:26:59
  提交了问题 2023-02-21 18:26:59

  如何查看odps的版本啊？

• 02.21 18:26:29
  提交了问题 2023-02-21 18:26:29

  恢复这个版本的分区报错如下是什么意思啊？

• 02.21 18:25:56
  提交了问题 2023-02-21 18:25:56

  不小心drop掉的分区，能补回来吗？

• 02.21 18:23:35
  提交了问题 2023-02-21 18:23:35

  DataWorks读mongodb到dm数据库涉及权限问题吗？

• 02.21 18:23:01
  提交了问题 2023-02-21 18:23:01

  mc里的结果表怎么对插入进来的数据自动去重呢？