flink native k8s 有计划支持hostAlias配置码?
请问社区有计划支持native k8s模式下配置hostAlais码? 如果自己扩展的话,需要在 模块中添加对应的hostAlais的配置项,并打包自定义的docker 镜像码? 谢谢~*来自志愿者整理的flink邮件归档
flink on native k8s资源弹性伸缩问题
我发现作业启动时消耗的资源量是最大的,但当作业运行起来后资源消耗量会下降。 这点从cpu消耗看更为明显,申请了2 vCore (Request == Limit),作业启动会用到 1.2 vCore,但当作业运行起来后实际只用到了0.8 vCore不到,造成了CPU资源浪费。 请问有没有办法做到资源...
flink on native k8s application模式作业启动慢问题
同一个作业,在请求资源相同的情况下,使用flink on native k8s session mode和application mode启动时间相差十几倍。 在session mode下提交作业,最多需要2分钟。而在application mode下提交作业,少则10分钟,多则半个小时至一个小时。...
flink on native k8s调度控制
flink作业跑在一个k8s集群,该集群下面有若干个节点,想将某些节点给部门A使用,其他节点给部门B使用。请问flink有配置控制k8s调度吗? 1. 给节点打上标签 2. 作业提交的时候设置调度标签值*来自志愿者整理的flink邮件归档
Flink1.13.3 on Native K8s 任务取消问题
你好,最近在使用Flink1.13.3 Native K8s应用模式部署任务,有几个问题不太理解: 1.在UI页面点击取消取消任务,马上又会重新拉起,达不到取消任务的目的? 2.通过kubectl delete deployment/cluster_id命令删除任务后,通过bin/flink run...
flink 1.11 on k8s native session cluster模式报找不到conf
大佬们,请教个问题,我是在k8s上部署flink1.11 natvie session模式。 下载的flink-1.11.0-bin-scala_2.11.tgz 执行命令是 ./bin/kubernetes-session.sh \ -Dkubernetes.cluster-id=k8s-sess...
flink on native k8s
flink on native k8s 按照官网配置,可以看到jobmanager ui 但是没有tm为0 slot为0 提交任务 就会一直卡主 角色配置: [root@node20 rbac]# cat rbac-role.yaml kind: Role apiVersion: rbac.auth...
flink on native k8s 无法查看火焰图问题
Unable to load requested file /jobs/d2fcac59f4a42ad17ceba8c5371862bb/。。。。。。 请问这是什么原因啊,恳请大佬解惑*来自志愿者整理的flink邮件归档
flink on native kubernetes作业cpu实际使用量与请求量相差太大问题
我们使用Flink运行实时作业在Kubernetes,发现作业实际使用的CPU资源远远小于作业请求量,但是将作业请求量降低后发现作业启动不了。请问这是个案还是正常情况? 例如,我们一个作业请求了0.5个cpu,但实际使用量只有0.09左右,修改请求为0.2个cpu,作业启动不了。 现在整个k8s集群...
Flink on native k8s如何自定义挂载盘?
为了监控TM OOM情况发生,我们在启动作业的时候添加了如下参数 -Denv.java.opts.taskmanager="-XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=/var/log/oom.bin" 想在OOM发生的时候能生成HeapDump...
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
实时计算 Flink版您可能感兴趣
- 实时计算 Flink版cp
- 实时计算 Flink版设置
- 实时计算 Flink版HDFS
- 实时计算 Flink版SQL
- 实时计算 Flink版版本
- 实时计算 Flink版任务
- 实时计算 Flink版sp
- 实时计算 Flink版oracle
- 实时计算 Flink版消耗
- 实时计算 Flink版迁移
- 实时计算 Flink版CDC
- 实时计算 Flink版数据
- 实时计算 Flink版mysql
- 实时计算 Flink版同步
- 实时计算 Flink版报错
- 实时计算 Flink版kafka
- 实时计算 Flink版表
- 实时计算 Flink版Apache
- 实时计算 Flink版配置
- 实时计算 Flink版实时计算
- 实时计算 Flink版flink
- 实时计算 Flink版 CDC
- 实时计算 Flink版模式
- 实时计算 Flink版运行
- 实时计算 Flink版数据库