问答 2019-11-21 来自:开发者社区

Flink任务,delay极高,请问你有什么调优策略?

Flink任务,delay极高,请问你有什么调优策略?

文章 2019-08-05 来自:开发者社区

58 集团大规模 Storm 任务平滑迁移至 Flink 的秘密

Flink-Storm 是 Flink 官方提供的用于 Flink 兼容 Storm 程序 beta 工具,并且在 Release 1.8 之后去掉相关代码。本文主要讲述 58 实时计算平台如何优化 Flink-Storm 以及基于 Flink-Storm 实现真实场景下大规模 Storm 任务平滑迁移 Flink。 背景 58 实时计算平台旨在为集团业务部门提供稳定高效实时计算服务,主要基于 ....

问答 2019-05-29 来自:开发者社区

cancel掉flink的任务会导致taskManager节点挂掉。

flink部署的是stand alone,在flink web UI上提交的任务(job 并行度2),进行cancel后会导致taskManager节点挂掉一个。在服务器上命令行用flink cancel jobID也是一样,会导致节点挂掉。

问答 2019-03-14 来自:开发者社区

cloudera manage flink 提交任务失败

在cloudera manage上面安装Flink,每台机器启动都有YarnSessionClusterEntrypoint进程,提交任务的时候,报错Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could n....

问答 2019-02-23 来自:开发者社区

flink从checkpoint中恢复任务失败

您好,请教一个问题。我手动执行命令从checkpoint中恢复,但是提示文件不存在。生成的checkpoint文件如下为什么不是我用savepoint恢复就可以成功状态后端用的是new FsStateBackend("file:///data/flink/checkpoints")

问答 2019-02-21 来自:开发者社区

flink on yarn任务失败了之后,错误日志从哪看有人知道吗?

转自钉钉群21789141:flink on yarn 任务失败了之后,错误日志从哪看有人知道吗?

问答 2019-02-14 来自:开发者社区

大家提交flink任务到yarn的时候 是在哪个节点提交的? namenode还是 datanode?

转自钉钉群21789141:大家提交flink任务到yarn的时候 是在哪个节点提交的? namenode还是 datanode?

问答 2019-01-10 来自:开发者社区

请问一下 storm topology转换为flink任务之后,可以支持on yarn模式运行吗?

请问一下storm topology转换为flink任务之后,可以支持on yarn模式运行吗?

问答 2019-01-03 来自:开发者社区

本地运行多个flink任务时,分析占的cpu、内存、时延情况,一般用什么方法或工具呀

本地运行多个flink任务时,分析占的cpu、内存、时延情况,一般用什么方法或工具呀

问答 2019-01-02 来自:开发者社区

flink任务从Checkpoint中恢复时,如果yarn-session 也关闭了, 怎么恢复?

当yarn-session存在时,恢复成功.当yarn-session不存在恢复时报错:Caused by: java.lang.RuntimeException: The Yarn application application_1545734329511_0092 doesn't run anymore.application application_1545734329511_0092 是....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注