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

咨询一个问题,flink on k8s application模式,flinksql任务提交到k8s

咨询一个问题,flink on k8s application模式,flinksql任务提交到k8s,jm能起来,tm起不来,jm的日志一直卡着,没有明显错误。 jm的日志卡这里了,不往下走了

问答 2023-02-10 来自:开发者社区

flink某一个算子的多个并行子任务中,有没有可能某一个子任务已经close了,别的子任务还没有完成

flink某一个算子的多个并行子任务中,有没有可能某一个子任务已经close了,别的子任务还没有完成open呢?

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

解决Flink流式任务的性能瓶颈

都说“过早进行性能优化是万恶之源”,我宁肯相信这是为了“矫枉过正”而出此惊人之语,更何况,现在的IT时代已与Donald Knuth的时代已有很大差异了。重点还是在于“过早”这个词,之所以Knuth告诫我们不要过早进行性能优化,原因在于:判断性能是否存在问题,不能太早太早做性能优化,有可能并没有弄清楚性能瓶颈在哪里⚜ 2016年8月,我有机会在斯坦福大学小住,与朋友在计算机学院William G....

解决Flink流式任务的性能瓶颈
问答 2023-02-06 来自:开发者社区

flink任务跑着跑着,内存使用率就会达到90%多,正常么?节点配置是4c8g的

flink任务跑着跑着,内存使用率就会达到90%多,正常么?节点配置是4c8g的

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

生产环境 部署flinksql 任务( flink on yarn )太消耗slot.怎么办?

想请教下生产环境 部署flinksql 任务( flink on yarn )太消耗slot.这个要怎么解决. 是把slot 和cpu之比调大吗? 具体比例多少合适啊?

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

如果Flink CDC pgsql库10几分钟更新几千万条数据,如何保证cdc任务不报错,内存不溢出

如果Flink CDC pgsql库10几分钟更新几千万条数据,复制槽一下子从几十M到几千M,这种情况下如何保证cdc任务不报错,内存不溢出

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

运行中的Flink任务能根据任务id反查到启动时的代码和参数配置吗?忘记任务是怎么启的了

运行中的Flink任务能根据任务id反查到启动时的代码和参数配置吗?忘记任务是怎么启的了

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

我现在有一个flink任务,部署在k8s上,老是报oom kill。并且任务重启之后报akka fr

我现在有一个flink任务,部署在k8s上,老是报oom kill。并且任务重启之后报akka frame size不够,请问这种是由于增量checkpoint保存的文件路径过多导致的吗?还是啥原因啊?目前TM 4g大小,数据量不大,资源我感觉是很足够的,但是还是oom kill了,应该是overhead 内存不够导致的,但是不知道怎么解决了

文章 2023-02-05 来自:开发者社区

一文搞懂Flink架构与任务编排|青训营笔记

前言本文主要讲述Flink的整体架构,以及流处理任务涉及的各个算子的调度编排机制。为模仿实现一个简易流处理引擎作下铺垫。具体流处理引擎编写的部分也将在后续以专栏形式进行整理发布。Flink 是一个分布式系统,需要有效分配和管理计算资源才能执行流式应用程序,它集成了所有常见的集群资源管理器,如 Hadoop YARN、Apache Mesos 和 Kubernetes,但也可以设置为作为独立集群甚....

一文搞懂Flink架构与任务编排|青训营笔记
问答 2023-01-29 来自:开发者社区

在提交一个finksql 任务的时候报这个错误,是不是我flink集群有问题呀?

在提交一个finksql 任务的时候报这个错误,是不是我flink集群有问题呀?

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

产品推荐

阿里云实时计算Flink

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

+关注