问答 2024-01-24 来自:开发者社区

使用flink native k8s的nodeport模式,能指定暴露的port吗?

使用flink native k8s的nodeport模式,能指定暴露的port吗?

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

Flink CDC native on k8s ,使用了HA机制,大概发布了几百个任务?

Flink CDC native on k8s ,使用了HA机制,大概发布了几百个任务,这样情况下隔一段时间 会导致k8s的api-server挂掉一次?访问ETCD的时间延迟较大,达到了200ms

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

老师我想问问有没有官方Flink CDC 1.17 on native k8s的相关部署文档?

老师我想问问有没有官方Flink CDC 1.17 on native k8s的相关部署文档?

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

集度汽车 Flink on native k8s 的应用与实践

摘要:本文整理自集度汽车数据部门实时方向负责人、 Apache Flink Contributor 周磊&集度汽车数据开发专家顾云,在 FFA 2022 行业案例专场的分享。本篇内容主要分为四个部分:集度实时计算发展FlinkSQL 实时入仓实践Flink 计算平台建设未来规划点击查看直播回放和演讲 PPT一、集度实时计算发展2021 年 3 月集度汽车成立。2021 年 11 月 Fl....

集度汽车 Flink on native k8s 的应用与实践
问答 2021-12-08 来自:开发者社区

flink1.12.0 native k8s启动不了

1、使用以下命令发布任务: ./bin/flink run-application --target kubernetes-application -Dkubernetes.cluster-id=my-first-application-cluster \ -Dkubernetes.container.image=registry.cn-shenzhen.aliyuncs.com/syni...

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

flink native k8s 有计划支持hostAlias配置码?

请问社区有计划支持native k8s模式下配置hostAlais码? 如果自己扩展的话,需要在 模块中添加对应的hostAlais的配置项,并打包自定义的docker 镜像码? 谢谢~*来自志愿者整理的flink邮件归档

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

flink on native k8s资源弹性伸缩问题

我发现作业启动时消耗的资源量是最大的,但当作业运行起来后资源消耗量会下降。 这点从cpu消耗看更为明显,申请了2 vCore (Request == Limit),作业启动会用到 1.2 vCore,但当作业运行起来后实际只用到了0.8 vCore不到,造成了CPU资源浪费。 请问有没有办法做到资源弹性伸缩,即以我申请vCore数为上限,留有20% buffer应付流量高峰,除此之外在作业运行过....

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

flink on native k8s application模式作业启动慢问题

同一个作业,在请求资源相同的情况下,使用flink on native k8s session mode和application mode启动时间相差十几倍。 在session mode下提交作业,最多需要2分钟。而在application mode下提交作业,少则10分钟,多则半个小时至一个小时。 1. 想问一下作业启动速度跟什么有关? 2. 要怎么提高作业启动速度呢?*来自志愿者整理的fli....

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

flink on native k8s调度控制

flink作业跑在一个k8s集群,该集群下面有若干个节点,想将某些节点给部门A使用,其他节点给部门B使用。请问flink有配置控制k8s调度吗? 1. 给节点打上标签 2. 作业提交的时候设置调度标签值*来自志愿者整理的flink邮件归档

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

Flink1.13.3 on Native K8s 任务取消问题

你好,最近在使用Flink1.13.3 Native K8s应用模式部署任务,有几个问题不太理解: 1.在UI页面点击取消取消任务,马上又会重新拉起,达不到取消任务的目的? 2.通过kubectl delete deployment/cluster_id命令删除任务后,通过bin/flink run-application方式启动任务,会自动从上次最后一个成功Checkpoint进行恢复,有什么....

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

产品推荐

实时计算 Flink

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

+关注