You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "You Chu (JIRA)" <ji...@apache.org> on 2018/04/08 15:02:00 UTC
[jira] [Updated] (FLINK-9148) when deploying flink on kubernetes,
the taskmanager report "java.net.UnknownHostException: flink-jobmanager:
Temporary failure in name resolution"
[ https://issues.apache.org/jira/browse/FLINK-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
You Chu updated FLINK-9148:
---------------------------
Description:
refer to https://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)
I know that the the
jobmanager-deployment.yaml
taskmanager-deployment.yaml
I know in flink docker image, it uses environment {{JOB_MANAGER_RPC_ADDRESS=flink-jobmanager to resolve jobmanager address. however in flink task container, it can't resolve the hostname flink-jobmanager.
Can anyone help me to fix it? Should I need to setup a DNS to resolve?}}
was:
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)
> 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
> Priority: Blocker
>
> refer to https://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)
>
> I know that the the
> jobmanager-deployment.yaml
> taskmanager-deployment.yaml
> I know in flink docker image, it uses environment {{JOB_MANAGER_RPC_ADDRESS=flink-jobmanager to resolve jobmanager address. however in flink task container, it can't resolve the hostname flink-jobmanager.
> Can anyone help me to fix it? Should I need to setup a DNS to resolve?}}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)