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

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

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

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

有大佬做native flink on k8s的部署方案吗

有大佬做native flink on k8s的部署方案吗

问答 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 来自:开发者社区

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

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

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

flink on native k8s jobManger频繁重启是什么原因导致的?

Hi, flink 1.12.1 on native k8s application模式,jobManager频繁重启可能是什么原因导致的,报错日志如下: "2021-08-26 12:41:12,891 DEBUG org.apache.flink.runtime.io.network.partition.ResourceManagerPartitionTrackerImpl [] - Pr.....

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

flink on native k8s要如何动态改变日志配置?

flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger Level,以及用户可以传入自定义的日志模板,目前有办法做到么?*来自志愿者整理的flink邮件归档

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

Flink application on native k8s如何修改配置文件?

Hi all, 最近再把flink任务迁移到native k8s,发现flink-conf系列的文件没有办法很好地被修改,比如log4j文件还有一些很通用的写在flink-conf的配置项(e.g. Prometheus配置)。 flink-conf的配置我还可以在flink run的时候带上,那log4j的配置好像没有太好的办法带上。 大家在这块有什么实践吗?thx.*来自志愿者整理的f...

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

产品推荐

阿里云容器服务 ACK

云端最佳容器应用运行环境,安全、稳定、极致弹性

+关注