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

Flink任务中DAG图每个节点WaterMark显示Long.MAX_VALUE

Flink任务中DAG图每个节点WaterMark显示Long.MAX_VALUE

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之新表启动后其他任务已经完成,而DAG图上的busy状态仍然为100,并且保留的task的backpressure为0,是什么导致的

问题一:Flink CDC我在配置文件分配了三个G 没提交任务是只占用了100m 现在已经增长到1.7G? Flink CDC我在配置文件分配了三个G 没提交任务是只占用了100m 全量阶段跑完后占用1.6G 然后就一直不动了。现在已经增长到1.7G? ...

实时计算 Flink版产品使用合集之新表启动后其他任务已经完成,而DAG图上的busy状态仍然为100,并且保留的task的backpressure为0,是什么导致的
问答 2024-04-15 来自:开发者社区

在flink cdc同步单表数据时,关闭后会导致数据不一致?什么情况下适合开启?

在flink cdc同步单表数据时,基于sql的实现方式中发现了作业DAG有个SinkMaterializer算子,检查checkpoint历史时发现该算子state越来越大,可以关闭吗?

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

Flink CDC中dinky后期打算支持DAG开发吗?flink的内部的DAG

Flink CDC中dinky后期打算支持DAG开发吗?flink的内部的DAG

问答 2023-03-15 来自:开发者社区

Flink这DAG 图的意思 是三个sink 各走各的中间的共同逻辑不复用吗?

再一个main 方面里面 输出了三个sink ,我画红色框的是相同的中间逻辑表 , 这DAG 图的意思 是三个sink 各走各的中间的共同逻辑不复用吗?

问答 2022-12-16 来自:开发者社区

Flink任务中DAG图每个节点WaterMark显示Long.MAX_VALUE

Flink任务中DAG图每个节点WaterMark显示Long.MAX_VALUE

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

flink sql 给DAG算子命名咋弄哇?就是,name 那种用法。有人知道么

flink sql 给DAG算子命名咋弄哇?就是,name 那种用法。有人知道么

问答 2022-04-21 来自:开发者社区

Flink的Function里的成员变量可以直接在main中构造DAG时就在构造函数里赋么

Flink的Function里的成员变量可以直接在main中构造DAG时就在构造函数里赋么。是可序列化的,且不修改的。如果task restart 这个成员变量的值可以复原吧?

问答 2022-02-15 来自:开发者社区

flink1.11 web ui没有DAG

本地linux下单机版安装的,提交flink代码运行后,正常运行,有日志,但是为啥UI上面却不显示数据接收和发送的条数,求大佬解答 *来自志愿者整理的flink邮件归档

问答 2021-12-12 来自:开发者社区

Flink Client DAG是什么?

Flink Client DAG是什么?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等