萝卜丝丸子_个人页

2024年08月

• 08.07 19:04:59
  提交了问题 2024-08-07 19:04:59

  PyFlink + AutoStream 的集成解决了什么问题？

• 08.07 19:04:44
  提交了问题 2024-08-07 19:04:44

  如何在 SQL 任务中使用 Python UDF？

• 08.07 19:04:34
  提交了问题 2024-08-07 19:04:34

  用户如何在原有项目中开发 PyFlink UDF？

• 08.07 19:04:26
  提交了问题 2024-08-07 19:04:26

  能否给出一个 PyFlink 自定义任务的事例？

• 08.07 19:04:13
  提交了问题 2024-08-07 19:04:13

  PyFlink 如何与 AutoStream 平台的 catalog 打通？

• 08.07 19:04:04
  提交了问题 2024-08-07 19:04:04

  如何优化 PyFlink 在 Kubernetes 上的部署以提高效率？

• 08.07 19:03:56
  提交了问题 2024-08-07 19:03:56

  PyFlink 支持哪三种依赖管理？

• 08.07 19:03:46
  提交了问题 2024-08-07 19:03:46

  为什么选择 Kubernetes 来部署 PyFlink 环境？

• 08.07 19:03:38
  提交了问题 2024-08-07 19:03:38

  湖仓一体架构的落地带来了哪些主要收益？

• 08.07 19:03:29
  提交了问题 2024-08-07 19:03:29

  改造后，事务 4 之后的 datafile 的 sequence number 是多少？

• 08.07 19:02:42
  提交了问题 2024-08-07 19:02:42

  为什么对 Iceberg 的小文件合并进行了改造？

• 08.07 19:02:33
  提交了问题 2024-08-07 19:02:33

  Iceberg在v2格式下，小文件合并如何影响实时写入事务，以及你们是如何解决这个问题的？

• 08.07 19:02:25
  提交了问题 2024-08-07 19:02:25

  在Iceberg中，为什么需要对v2格式的小文件进行合并，以及合并过程中需要注意哪些问题？

• 08.07 19:02:16
  提交了问题 2024-08-07 19:02:16

  Iceberg如何实现upsert语义，特别是在v2格式中？

• 08.07 19:02:08
  提交了问题 2024-08-07 19:02:08

  Iceberg表元数据文件被误删会导致什么问题，以及你们是如何解决这个问题的？

• 08.07 19:01:59
  提交了问题 2024-08-07 19:01:59

  为什么选择使用基于zk的分布式锁替换Hive Metastore的默认锁机制？

• 08.07 19:01:50
  提交了问题 2024-08-07 19:01:50

  在湖仓一体架构中，你们遇到了哪些稳定性和数据正确性的问题，并如何解决？

• 08.07 19:01:41
  提交了问题 2024-08-07 19:01:41

  在实时入湖阶段，Flink如何与离线团队的账号体系打通？

• 08.07 19:01:34
  提交了问题 2024-08-07 19:01:34

  Iceberg表如何反映数据的写入进度，以便离线调度精确触发下游任务？

• 08.07 19:01:25
  提交了问题 2024-08-07 19:01:25

  Flink在写入Iceberg表时，如何确保主键相同的数据写入到同一个bucket？

• 08.07 19:01:17
  提交了问题 2024-08-07 19:01:17

  在你们的湖仓一体架构中，Iceberg是如何与Hive和HDFS集成的？

• 08.07 19:01:07
  提交了问题 2024-08-07 19:01:07

  Iceberg的增量快照机制是如何工作的？

• 08.07 19:00:58
  提交了问题 2024-08-07 19:00:58

  基于Iceberg构建的湖仓一体架构主要解决了Hive数据仓库的哪些痛点？

• 08.07 19:00:49
  提交了问题 2024-08-07 19:00:49

  为什么需要将伸缩容后的资源设置持久化到zk和HDFS？

• 08.07 19:00:41
  提交了问题 2024-08-07 19:00:41

  在伸缩容过程中，如何确保任务从旧taskmanager平稳过渡到新taskmanager？

• 08.07 19:00:32
  提交了问题 2024-08-07 19:00:32

  在自动伸缩容过程中，如果伸缩容失败，资源设置是如何回滚的？

• 08.07 19:00:24
  提交了问题 2024-08-07 19:00:24

  自动伸缩容过程中，第一步如何向ResourceManager申请新container并为其打标记的？

• 08.07 18:59:53
  提交了问题 2024-08-07 18:59:53

  自动伸缩容功能是如何实现的？

• 08.07 18:59:43
  提交了问题 2024-08-07 18:59:43

  自动伸缩容功能的主要目的是什么？

• 08.07 18:59:35
  提交了问题 2024-08-07 18:59:35

  如何识别并处理低利用率任务？

• 08.07 18:59:17
  提交了问题 2024-08-07 18:59:17

  为什么需要实施预算资源管控策略？

• 08.07 18:59:08
  提交了问题 2024-08-07 18:59:08

  AutoStream 3.0相较于2.0版本在哪些方面进行了升级？

• 08.07 18:58:31
  提交了问题 2024-08-07 18:58:31

  为什么选择Flink和Iceberg来构建实时湖仓一体的架构？

• 08.07 18:58:23
  提交了问题 2024-08-07 18:58:23

  推动用户进行资源调优存在哪些挑战？

• 08.07 18:58:13
  提交了问题 2024-08-07 18:58:13

  随着公司容器化建设的推进，你们采取了哪些措施来改善资源分配问题？

• 08.07 18:57:58
  提交了问题 2024-08-07 18:57:58

  在AutoStream 2.0架构中，你们遇到了哪些痛点？

• 08.07 18:57:50
  提交了问题 2024-08-07 18:57:50

  AutoStream 3.0的主要升级内容是什么？

• 08.07 18:57:39
  提交了问题 2024-08-07 18:57:39

  在实时计算平台的发展过程中，你们经历了哪些阶段？

• 08.07 18:57:22
  提交了问题 2024-08-07 18:57:22

  汽车之家的应用场景主要包括哪些方面？

• 08.07 18:57:13
  提交了问题 2024-08-07 18:57:13

  如何评估一个需求开发中的重大风险？

• 08.07 18:56:21
  提交了问题 2024-08-07 18:56:21

  代码重构时，如果不指定switch的namespace，可能会导致什么后果？

• 08.07 18:56:12
  提交了问题 2024-08-07 18:56:12

  switch的持久值是如何工作的，为什么需要特别注意代码中的默认值？

• 08.07 18:56:02
  提交了问题 2024-08-07 18:56:02

  switch发布时，为什么需要特别注意不同批次的时间间隔可能引发的问题？

• 08.07 18:55:53
  提交了问题 2024-08-07 18:55:53

  为什么在设置默认值时需要特别注意异常发生的风险？

• 08.07 18:55:44
  提交了问题 2024-08-07 18:55:44

  在失败处理中，有哪些常见的处理方式，并解释其含义？

• 08.07 18:55:37
  提交了问题 2024-08-07 18:55:37

  如何处理热点key问题？

• 08.07 18:55:28
  提交了问题 2024-08-07 18:55:28

  缓存命中率低可能说明什么问题？

• 08.07 18:55:19
  提交了问题 2024-08-07 18:55:19

  如何保证缓存和数据库之间的数据强一致性？

• 08.07 18:55:09
  提交了问题 2024-08-07 18:55:09

  如何避免缓存雪崩问题？

• 08.07 18:52:32
  提交了问题 2024-08-07 18:52:32

  缓存穿透问题是什么？如何解决？