李贵发
当使用 OSS 作为资源存储时，会出现如下报错。rs 是配置的上传目录的根路径。错误的原因在于生成的路径是相对路径，而相对路径会被判断为不存在。如果将上传目录的根路径以 '/' 开头，可以避免该错误，但会导致 Flink 无法启动。为解决这个问题，应在生成根路径时判断其是否以 '/' 开头，如果不是，则自动在前面添加 '/'。 [dinky] 2025-08-25 17:25:01 CST ERROR org.apache.flink.runtime.webmonitor.history.HistoryServerArchiveFetcher 232 fetchArchives - Critical failure while fetching/processing job archives. java.lang.IllegalArgumentException: Path is not...
添加一个/metric/prometheus接口，用于导出flink任务的监控数据给prometheus 1、 /metric/prometheus 导出全部的监控数据 2、/metric/prometheus/STATUS 导出任务状态数据 3、/metric/prometheus/JOBMANAGER 导出jobmanager的监控数据 4、/metric/prometheus/TASKMANAGER 导出taskmanager的监控数据 5、/metric/prometheus/VERTICES 导出vertices的监控数据
**问题** 在以下场景下，任务实际仍在运行，但 Dinky 显示任务状态为失败或未知，且任务名旁的小火苗消失： 1. 任务由 Flink Operator 管理，Operator对任务进行重新部署后导致jobId 发生变化。 2. 任务由 Flink Operator 管理，失败的任务被重新拉起并成功运行。 3. K8s 模式下，Dinky 启动任务超时，但任务实际已在 K8s 中启动成功。 4. K8s 模式下，任务 pod 被临时缩容为 0，导致 Dinky 误判为失败。 5....