apache-samza - 应用部署在yarn中时samza如何生成container.id?
问题描述
当应用程序部署在纱线中时,有人可以告诉我 samza 如何生成samza.container.id / SAMZA_CONTAINER_ID吗?我在 samza 代码库中环顾四周,但无法找到生成的逻辑samza.container.id
解决方案
在 YARN 环境中,Samza 使用 YARN 生成的 containerIds 作为环境变量来设置每个容器进程的 samza.container.id。即,当 YARN 中的 Samza AM 进程请求容器时,YARN RM 将回复一组分配的容器对象,这些对象属于 org.apache.hadoop.yarn.api.records.Container 类。这是在 YARN 中唯一标识容器的资源类,Container#getId().toString() 是我们设置为 samza.container.id 的容器 ID 字符串。
从 YARN RM 的响应中获取容器 ID 的代码位于YarnClusterResourceManager#onContainersAllocated()
推荐阅读
- python - Paramiko SFTPAttributes 中的属性
- jquery - ajax onSuccess 方法填充后,ASP.NET 禁用数据网格按钮
- mysql - 如何根据 table2 中的某些特定列在 table1 中获取 COUNT
- r - 如何根据数字范围将列按其值分组为 3 组
- python - Python - 使用 ETag 和修改的提要更新给出 200 但提要未更新
- bulma - b表为空时如何隐藏分页按钮
- r - R sfnetworks,用来自shapfile的ID替换图形中的边ID?
- android - 不同帐户上的密钥库和 sha1 相似性识别
- sql - 为什么我在这 2 个 SQL 查询中得到不同的结果?单独使用 AVG 与使用 over() 时
- c++ - 使用多个插入准备查询