[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488151#comment-17488151
]
Yuan Huang commented on FLINK-24947:
-------------------------------------
Hi, [~spoon-lz] . Thank you for your work. I am very interested in this host
network functionality as well.
After looking at your code, I am a little confused about how Task Manager
connects to the newly started Job manager. According to your comments: "In
non-HA mode, after the JobManager fails over and started, it will use the new
port (6123) to modify the InternalService, so that the TaskManager can still
obtain the correct JobManager address information through the InternalService",
Flink will work normally in non-HA mode. But I did not see any code about how
Task Manager queried the internal service and got the correct port.
So just want to confirm how the code works in this part.
> Support host network for native K8s integration
> -----------------------------------------------
>
> Key: FLINK-24947
> URL: https://issues.apache.org/jira/browse/FLINK-24947
> Project: Flink
> Issue Type: New Feature
> Components: Deployment / Kubernetes
> Reporter: liuzhuo
> Assignee: liuzhuo
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> For the use of flink on k8s, for performance considerations, it is important
> to choose a CNI plug-in. Usually we have two environments: Managed and
> UnManaged.
> Managed: Cloud vendors usually provide very efficient CNI plug-ins, we
> don’t need to care about network performance issues
> UnManaged: On self-built K8s clusters, CNI plug-ins are usually optional,
> similar to Flannel and Calcico, but such software network cards usually lose
> some performance or require some additional network strategies.
> For an unmanaged environment, if we also want to achieve the best network
> performance, should we support the *HostNetWork* model?
> Use the host network to achieve the best performance
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
