阿里云文档 2025-06-05

创建和运行工作流

工作流是通过拖拽任务节点并建立任务节点之间的关联来创建可视化的DAG(有向无环图)。如果您需要安排任务在指定的时间运行,可以创建工作流并在工作流中定义调度节点以及调度策略。本文为您介绍如何创建和运行工作流。

阿里云文档 2025-03-26

如何通过阿里云日志服务收集结束运行的Flink作业的日志

本文为您介绍如何通过阿里云日志服务收集结束运行的Flink作业的日志。

问答 2024-08-07 来自:开发者社区

在Flink CDC中,使用Flink HA模式可以做到flink集群重启后自动恢复运行的job吗?

在Flink CDC中,使用Flink HA模式可以做到flink集群重启后自动恢复正在运行的job吗?

问答 2024-08-06 来自:开发者社区

使用Flink HA模式可以做到flink集群重启后自动恢复正在运行的job吗?

使用Flink HA模式可以做到flink集群重启后自动恢复正在运行的job吗?

问答 2024-06-09 来自:开发者社区

Flink哪些source支持批模式运行

Flink哪些source支持批模式运行

问答 2024-04-22 来自:开发者社区

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

Flink遇到一个问题请教一下,flink application模式,部署在k8s运行,任务完成归档到对象存储,重跑任务时报错ERROR org.apache.flink.runtime.history.FsJobArchivist [] - Failed to archive job. java.io.IOException: File already exi...

文章 2023-11-08 来自:开发者社区

在Flink CDC中,本地模式(Local Mode)是指Flink任务在单个节点上运行

在Flink CDC中,本地模式(Local Mode)是指Flink任务在单个节点上运行,不启用任务并行度,所有算子都在一个线程中执行。在这种模式下,Flink CDC可以实现断点续传。 具体来说,你可以通过以下步骤来实现断点续传: 在全量同步开始前,记录同步位置。这可...

问答 2023-08-22 来自:开发者社区

在Flink怎么用流模式像批运行一样,只输出分组聚合的最后结果呢?

在Flink怎么用流模式像批运行一样,只输出分组聚合的最后结果呢?不需要流模式运行的中间结果,请问大佬们遇到过吗?

问答 2023-06-27 来自:开发者社区

flink Standalone-HA模式,当运行中的taskmanager宕机或被误杀后,

flink Standalone-HA模式,当运行中的taskmanager宕机或被误杀后,导致整个作业挂了。 想问下,有没有办法当taskmanager宕机或被误杀后, JobManager 有没有办法将宕机掉taskmanager,进行重新分配到新的机器上, 保证作业正常运行,而不是让作业挂了

问答 2023-05-22 来自:开发者社区

请教各位老师一个问题,flink on yarn 模式下跑流作业在运行过程中,突然挂掉?

请教各位老师一个问题,flink on yarn 模式下跑流作业在运行过程中,突然jobmanager挂掉。然后看jobmanager没有报错,只有一条这种日志。看来当时服务器cpu和内存也不高。不知道为什么会收到这种kill信号。RECEIVED SIGNAL 15: SIG SIGTERM. Shutting down as requested。有老师能指点一下吗?

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

产品推荐

阿里云实时计算Flink

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

+关注