feature: support multi cluster #31
Conversation
|
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: The full list of commands accepted by this bot can be found here.
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
Suozz
force-pushed
the
support_multi_cluster_remote
branch
2 times, most recently
from
a1bdf9e
to
0468b3d
Compare
koordinator-bot
bot
added
size/XL
and removed
do-not-merge/invalid-owners-file
size/XXL
labels
| yarnNodeIdAnnotation = "yarn.hadoop.apache.org/node-id" | ||
| //yarnNodeNameAnnotation = "node.yarn.koordinator.sh" | ||
| yarnNodeAllocatedResourceAnnotationKey = "neptune.xhs.com/resourceAllocated" | ||
| actualOfflineResourceAnnotationKey = "neptune.xhs.com/actualOfflineResource" |
There was a problem hiding this comment.
use name like node.yarn.koordinator.sh/neptune.xhs.com/resourceAllocated
| @@ -217,10 +216,6 @@ func setupConnection(c *Client) (*connection, error) { | |||
| } | |||
|
|
|||
| func writeConnectionHeader(conn *connection, authProtocol yarnauth.AuthProtocol) error { | |||
| if err := conn.con.SetDeadline(time.Now().Add(rwDefaultTimeout)); err != nil { | |||
There was a problem hiding this comment.
should keep timeout deadline
| @@ -279,7 +270,7 @@ func writeConnectionContext(c *Client, conn *connection, connectionId *connectio | |||
| return err | |||
| } | |||
|
|
|||
| ipcCtxProtoBytes, err := proto.Marshal(&ipcCtxProto) | |||
* filter finished yarn container * yarn resource sync to k8s * yarn node resource metrics Signed-off-by: suozengzeng <suozengzeng@xiaohongshu.com>
Suozz
force-pushed
the
support_multi_cluster_remote
branch
from
0468b3d
to
de69c24
Compare
koordinator-bot
bot
added
size/XXL
do-not-merge/invalid-owners-file
and removed
size/XL
labels
|
The following users are mentioned in OWNERS file(s) but are untrusted for the following reasons. One way to make the user trusted is to add them as members of the koordinator-sh org. You can then trigger verification by writing
|
Ⅰ. Describe what this PR does
Ⅱ. Does this pull request fix one issue?
Ⅲ. Describe how to verify it
Ⅳ. Special notes for reviews
V. Checklist
make test