开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink遇到一个问题请教一下,flink application模式,部署在k8s运行,怎么解决?

Flink遇到一个问题请教一下,flink application模式,部署在k8s运行,任务完成归档到对象存储,重跑任务时报错ERROR org.apache.flink.runtime.history.FsJobArchivist [] - Failed to archive job. java.io.IOException: File already exists: ,发现每次重新跑任务生成的jobId都是相同的, 在归档存储目录已经存在相同jobId的归档文件,这个问题怎么解决啊?

展开
收起
真的很搞笑 2024-04-22 19:05:53 19 0
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    ACK 云原生弹性方案—云原生时代的加速器 立即下载
    ACK集群类型选择最佳实践 立即下载
    企业运维之云原生和Kubernetes 实战 立即下载

    相关镜像