船长的小螺号_个人页

2021年12月

• 12.03 10:29:04
  提交了问题 2021-12-03 10:29:04

  ParquetTableSource在blink table planner下的使用问题

• 12.03 10:28:44
  提交了问题 2021-12-03 10:28:44

  flink rocksdb状态后端物理内存溢出的问题

• 12.03 10:28:20
  提交了问题 2021-12-03 10:28:20

  flink-1.10.0通过run -m yarn-cluster提交任务时异常

• 12.03 10:27:55
  提交了问题 2021-12-03 10:27:55

  如果有些map阶段的计算很慢，它发checkpoint也很慢，那么这样会阻塞reduce opera

• 12.03 10:27:20
  提交了问题 2021-12-03 10:27:20

  Flink读写kafka数据聚集任务失败问题

• 12.03 10:26:54
  提交了问题 2021-12-03 10:26:54

  [FLI]求大佬翻牌，看一个checkpoint 被 decline 的问题。

• 12.03 10:23:46
  提交了问题 2021-12-03 10:23:46

  使用flink-jdbc-driver写入mysql时失败(flink1.10.0)

• 12.03 10:23:17
  提交了问题 2021-12-03 10:23:17

  Flink ReduceFunction 没有数据发送到下游

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

  flink rocksdb反压问题的处理

• 12.03 10:21:57
  提交了问题 2021-12-03 10:21:57

  Flink sql count 多个属性的问题

• 12.03 10:21:32
  提交了问题 2021-12-03 10:21:32

  关于在读和写频率都很高的情况下怎么优化rocksDB

• 12.03 10:21:00
  提交了问题 2021-12-03 10:21:00

  为什么窗口中的数据无法发送到下游？

• 12.03 10:20:30
  提交了问题 2021-12-03 10:20:30

  用FlinkKafkaProducer011写kafka的exactly once的困惑

• 12.03 10:20:06
  提交了问题 2021-12-03 10:20:06

  Flink 1.10连接hive时kerberos认证异常问题

• 12.03 10:15:56
  提交了问题 2021-12-03 10:15:56

  How should i set the field type in mysql when i us

• 12.03 10:15:29
  提交了问题 2021-12-03 10:15:29

  flink内存分配的问题

• 12.03 10:14:28
  提交了问题 2021-12-03 10:14:28

  FLINK 1.9.1 StreamingFileSink 压缩问题

• 12.03 10:14:01
  提交了问题 2021-12-03 10:14:01

  flink 创建hbase出错

• 12.03 10:13:25
  提交了问题 2021-12-03 10:13:25

  如何使用influxdb作为flink metrics reporter

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

  SQL层应用维表join jdbc的时候，请问怎么动态感知维表数据的变化呢？

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

  如何获取算子处理一条数据记录的时间

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

  使用Flink SQL时，碰到的 【Window can only be defined over

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

  注册table时catalog无法变更怎么解决？

• 12.03 10:06:33
  提交了问题 2021-12-03 10:06:33

  FLINK 不同 StateBackend ProcessWindowFunction的差别？

• 12.03 10:06:05
  提交了问题 2021-12-03 10:06:05

  求问怎么通过dashboard查看状态存储量之类的统计？如果没开checkpoint的话

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

  flink遇到 valueState 自身的 NPE怎么办？

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

  问一下Flink Plan Visualizer什么时候会更新成1.9的样式

• 12.03 10:02:30
  提交了问题 2021-12-03 10:02:30

  flink消费Kafka没有数据问题

• 12.03 10:01:21
  提交了问题 2021-12-03 10:01:21

  flink消费kafka数据，如何从kafka端获取消费偏移信息

• 12.03 10:00:13
  提交了问题 2021-12-03 10:00:13

  关于flink集群中调用dubbo服务的咨询

• 12.03 09:54:48
  提交了问题 2021-12-03 09:54:48

  流处理任务失败该如何追回之前的数据

• 12.03 09:52:01
  提交了问题 2021-12-03 09:52:01

  flink是否可以通过代码设置hadoop的配置文件目录