You'll have create the job manager service like mentioned in the link. http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Flink-on-Kubernetes-issue-tp21664.html
You should create job manager service before deploying the task manager. http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Flink-on-Kubernetes-issue-tp21664.html On Sun, Apr 8, 2018 at 8:28 PM, You Chu (JIRA) <j...@apache.org> wrote: > You Chu created FLINK-9148: > ------------------------------ > > Summary: when deploying flink on kubernetes, the taskmanager > report "java.net.UnknownHostException: flink-jobmanager: Temporary > failure in name resolution" > Key: FLINK-9148 > URL: https://issues.apache.org/jira/browse/FLINK-9148 > Project: Flink > Issue Type: Bug > Components: Docker > Affects Versions: 1.4.2 > Environment: kubernetes 1.9 > docker 1.4 > see :https://ci.apache.org/projects/flink/flink-docs- > release-1.4/ops/deployment/kubernetes.html > Reporter: You Chu > > > refer tohttps://ci.apache.org/projects/flink/flink-docs- > release-1.4/ops/deployment/kubernetes.html: > > I deploy flink1.4 on kubernetes 1.9, the jobmanager container is ok, but > the taskmanager contains failed with error: > > > java.net.UnknownHostException: flink-jobmanager: Temporary failure in name > resolution > at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) > at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:928) > at java.net.InetAddress.getAddressesFromNameService( > InetAddress.java:1323) > at java.net.InetAddress.getAllByName0(InetAddress.java:1276) > at java.net.InetAddress.getAllByName(InetAddress.java:1192) > at java.net.InetAddress.getAllByName(InetAddress.java:1126) > at java.net.InetAddress.getByName(InetAddress.java:1076) > at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils. > getRpcUrl(AkkaRpcServiceUtils.java:172) > at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils. > getRpcUrl(AkkaRpcServiceUtils.java:137) > at org.apache.flink.runtime.highavailability. > HighAvailabilityServicesUtils.createHighAvailabilityServices( > HighAvailabilityServicesUtils.java:79) > at org.apache.flink.runtime.taskmanager.TaskManager$. > selectNetworkInterfaceAndRunTaskManager(TaskManager.scala:1681) > at org.apache.flink.runtime.taskmanager.TaskManager$$anon$ > 2.call(TaskManager.scala:1592) > at org.apache.flink.runtime.taskmanager.TaskManager$$anon$ > 2.call(TaskManager.scala:1590) > at java.security.AccessController.doPrivileged(Native Method) > > > > -- > This message was sent by Atlassian JIRA > (v7.6.3#76005) >
