Glad to hear that you could deploy the Flink cluster on K8s natively. Thanks for trying the in-preview feature and give your feedback.
Moreover, i want to give a very simple conclusion here. Currently, because of the compatibility issue of fabric8 kubernetes-client, the native K8s integration have the following known limitation. * For jdk 8u252, the native k8s integration could only work on kubernetes v1.16 and lower versions. * For other jdk versions(e.g. 8u242, jdk11), i am not aware of the same issues. The native K8s integration works well. Best, Yang Dongwon Kim <eastcirc...@gmail.com> 于2020年5月9日周六 上午11:46写道: > Hi Yang, > > Oops, I forget to copy /etc/kube/admin.conf to $HOME/.kube/config so that > the current user account can access to K8s. > Now that I copied it, I found that kubernetes-session.sh is working fine. > Thanks very much! > > Best, > Dongwon > > [flink@DAC-E04-W06 ~]$ kubernetes-session.sh > 2020-05-09 12:43:49,961 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: jobmanager.rpc.address, DAC-E04-W06 > 2020-05-09 12:43:49,962 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: jobmanager.rpc.port, 6123 > 2020-05-09 12:43:49,962 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: jobmanager.heap.size, 1024m > 2020-05-09 12:43:49,962 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: taskmanager.memory.process.size, 24g > 2020-05-09 12:43:49,963 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: taskmanager.numberOfTaskSlots, 24 > 2020-05-09 12:43:49,963 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: parallelism.default, 1 > 2020-05-09 12:43:49,963 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: high-availability, zookeeper > 2020-05-09 12:43:49,963 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: high-availability.zookeeper.path.root, /flink > 2020-05-09 12:43:49,964 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: high-availability.storageDir, hdfs:///user/flink/ha/ > 2020-05-09 12:43:49,964 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: high-availability.zookeeper.quorum, DAC-E04-W06:2181 > 2020-05-09 12:43:49,965 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: jobmanager.execution.failover-strategy, region > 2020-05-09 12:43:49,965 INFO > org.apache.flink.configuration.GlobalConfiguration - Loading > configuration property: rest.port, 8082 > 2020-05-09 12:43:51,122 INFO > org.apache.flink.runtime.clusterframework.TaskExecutorProcessUtils - The > derived from fraction jvm overhead memory (2.400gb (2576980416 bytes)) is > greater than its max value 1024.000mb (1073741824 bytes), max value will be > used instead > 2020-05-09 12:43:51,123 INFO > org.apache.flink.runtime.clusterframework.TaskExecutorProcessUtils - The > derived from fraction network memory (2.291gb (2459539902 bytes)) is > greater than its max value 1024.000mb (1073741824 bytes), max value will be > used instead > 2020-05-09 12:43:51,131 INFO > org.apache.flink.kubernetes.utils.KubernetesUtils - Kubernetes > deployment requires a fixed port. Configuration blob.server.port will be > set to 6124 > 2020-05-09 12:43:51,131 INFO > org.apache.flink.kubernetes.utils.KubernetesUtils - Kubernetes > deployment requires a fixed port. Configuration taskmanager.rpc.port will > be set to 6122 > 2020-05-09 12:43:51,134 INFO > org.apache.flink.kubernetes.utils.KubernetesUtils - Kubernetes > deployment requires a fixed port. Configuration > high-availability.jobmanager.port will be set to 6123 > 2020-05-09 12:43:52,167 INFO > org.apache.flink.kubernetes.KubernetesClusterDescriptor - Create > flink session cluster flink-cluster-4a82d41b-af15-4205-8a44-62351e270242 > successfully, JobManager Web Interface: http://cluster-endpoint:31513 > > > On Sat, May 9, 2020 at 12:29 PM Yang Wang <danrtsey...@gmail.com> wrote: > >> Hi Dongwon Kim, >> >> Thanks a lot for your information. I will dig into this issue. >> >> I think the "UnknownHostException" is caused by incorrectly setting the >> Kubernetes >> ApiServer address. Maybe you are using "kubernetes.default.svc". However, >> it >> could not be accessed outside of the Kubernetes cluster. You need to >> configure >> a correct ip/hostname for ApiServer address, which could be accessed in >> your >> local environment. You could use `kubectl auth can-i create pods` to >> verify >> whether the kube config is correct. >> >> BTW, currently we only find the flink on native K8s could not work on >> 8u252. For >> 8u242 and lower version, it works well. >> >> >> Best, >> Yang >> >> Dongwon Kim <eastcirc...@gmail.com> 于2020年5月9日周六 上午10:43写道: >> >>> Hello Yang, >>> >>> I'm using K8s v1.18.2 installed by Kubeadm over a cluster of 5 nodes >>> (not a Minikube). >>> Previously, as you pointed out, openjdk version "1.8.0_252" was >>> installed. >>> I bump up java version to openjdk 11.0.7 but got something different: >>> >>> [flink@DAC-E04-W06 bin]$ ./kubernetes-session.sh >>> 2020-05-09 11:39:36,737 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: jobmanager.rpc.address, DAC-E04-W06 >>> 2020-05-09 11:39:36,739 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: jobmanager.rpc.port, 6123 >>> 2020-05-09 11:39:36,739 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: jobmanager.heap.size, 1024m >>> 2020-05-09 11:39:36,739 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: taskmanager.memory.process.size, 24g >>> 2020-05-09 11:39:36,739 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: taskmanager.numberOfTaskSlots, 24 >>> 2020-05-09 11:39:36,739 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: parallelism.default, 1 >>> 2020-05-09 11:39:36,740 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: high-availability, zookeeper >>> 2020-05-09 11:39:36,740 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: high-availability.zookeeper.path.root, /flink >>> 2020-05-09 11:39:36,740 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: high-availability.storageDir, hdfs:///user/flink/ha/ >>> 2020-05-09 11:39:36,740 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: high-availability.zookeeper.quorum, DAC-E04-W06:2181 >>> 2020-05-09 11:39:36,741 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: jobmanager.execution.failover-strategy, region >>> 2020-05-09 11:39:36,741 INFO >>> org.apache.flink.configuration.GlobalConfiguration - Loading >>> configuration property: rest.port, 8082 >>> 2020-05-09 11:39:36,817 WARN io.fabric8.kubernetes.client.Config >>> - Error reading service account token from: >>> [/var/run/secrets/kubernetes.io/serviceaccount/token]. Ignoring. >>> 2020-05-09 11:39:36,823 WARN io.fabric8.kubernetes.client.Config >>> - Error reading service account token from: >>> [/var/run/secrets/kubernetes.io/serviceaccount/token]. Ignoring. >>> 2020-05-09 11:39:37,080 WARN io.fabric8.kubernetes.client.Config >>> - Error reading service account token from: >>> [/var/run/secrets/kubernetes.io/serviceaccount/token]. Ignoring. >>> 2020-05-09 11:39:37,082 WARN io.fabric8.kubernetes.client.Config >>> - Error reading service account token from: >>> [/var/run/secrets/kubernetes.io/serviceaccount/token]. Ignoring. >>> 2020-05-09 11:39:37,334 ERROR >>> org.apache.flink.kubernetes.cli.KubernetesSessionCli - Error while >>> running the Flink session. >>> io.fabric8.kubernetes.client.KubernetesClientException: Operation: [get] >>> for kind: [Service] with name: >>> [flink-cluster-6adb7c62-8940-4828-990c-a87379102d61] in namespace: >>> [default] failed. >>> at >>> io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:64) >>> at >>> io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:72) >>> at >>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:231) >>> at >>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:164) >>> at >>> org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getService(Fabric8FlinkKubeClient.java:334) >>> at >>> org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getInternalService(Fabric8FlinkKubeClient.java:246) >>> at >>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.run(KubernetesSessionCli.java:104) >>> at >>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.lambda$main$0(KubernetesSessionCli.java:185) >>> at >>> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) >>> at >>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.main(KubernetesSessionCli.java:185) >>> Caused by: java.net.UnknownHostException: kubernetes.default.svc: Name >>> or service not known >>> at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) >>> at >>> java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:929) >>> at >>> java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1515) >>> at >>> java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:848) >>> at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1505) >>> at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1364) >>> at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1298) >>> at org.apache.flink.kubernetes.shadded.okhttp3.Dns$1.lookup(Dns.java:40) >>> at >>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RouteSelector.resetNextInetSocketAddress(RouteSelector.java:185) >>> at >>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RouteSelector.nextProxy(RouteSelector.java:149) >>> at >>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RouteSelector.next(RouteSelector.java:84) >>> at >>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:214) >>> >>> >>> Thanks a lot for your interest :-) >>> >>> Best, >>> >>> Dongwon >>> >>> On Sat, May 9, 2020 at 11:15 AM Yang Wang <danrtsey...@gmail.com> wrote: >>> >>>> Hi Dongwon Kim, >>>> >>>> Are you running Flink on a minikube or a real Kubernetes cluster? I >>>> just could not >>>> reproduce it in a real Kubernetes cluster with java 8u252. For >>>> minikube, i get the >>>> exception with you. >>>> >>>> >>>> Best, >>>> Yang >>>> >>>> Yang Wang <danrtsey...@gmail.com> 于2020年5月6日周三 上午9:29写道: >>>> >>>>> Hi Dongwon Kim, >>>>> >>>>> I think it is a known issue. The native kubernetes integration could >>>>> not work with jdk 8u252 >>>>> due to okhttp issue[1]. Currently, you could upgrade your jdk to a new >>>>> version to work around. >>>>> >>>>> >>>>> [1]. https://issues.apache.org/jira/browse/FLINK-17416 >>>>> >>>>> Dongwon Kim <eastcirc...@gmail.com> 于2020年5月6日周三 上午7:15写道: >>>>> >>>>>> Hi, >>>>>> >>>>>> I'm using Flink-1.10 and tested everything [1] successfully. >>>>>> While trying [2], I got the following message. >>>>>> Can anyone help please? >>>>>> >>>>>> [root@DAC-E04-W06 bin]# ./kubernetes-session.sh >>>>>>> 2020-05-06 08:10:49,411 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: jobmanager.rpc.address, DAC-E04-W06 >>>>>>> 2020-05-06 08:10:49,412 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: jobmanager.rpc.port, 6123 >>>>>>> 2020-05-06 08:10:49,412 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: jobmanager.heap.size, 1024m >>>>>>> 2020-05-06 08:10:49,412 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: taskmanager.memory.process.size, 24g >>>>>>> 2020-05-06 08:10:49,413 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: taskmanager.numberOfTaskSlots, 24 >>>>>>> 2020-05-06 08:10:49,413 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: parallelism.default, 1 >>>>>>> 2020-05-06 08:10:49,413 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: high-availability, zookeeper >>>>>>> 2020-05-06 08:10:49,413 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: high-availability.zookeeper.path.root, /flink >>>>>>> 2020-05-06 08:10:49,414 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: high-availability.storageDir, >>>>>>> hdfs:///user/flink/ha/ >>>>>>> 2020-05-06 08:10:49,414 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: high-availability.zookeeper.quorum, >>>>>>> DAC-E04-W06:2181 >>>>>>> 2020-05-06 08:10:49,414 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: jobmanager.execution.failover-strategy, region >>>>>>> 2020-05-06 08:10:49,415 INFO >>>>>>> org.apache.flink.configuration.GlobalConfiguration - Loading >>>>>>> configuration property: rest.port, 8082 >>>>>>> 2020-05-06 08:10:50,386 ERROR >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli - Error >>>>>>> while >>>>>>> running the Flink session. >>>>>>> io.fabric8.kubernetes.client.KubernetesClientException: Operation: >>>>>>> [get] for kind: [Service] with name: >>>>>>> [flink-cluster-5c12bd50-a540-4614-96d0-549785a8bc62] in namespace: >>>>>>> [default] failed. >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:64) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:72) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:231) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:164) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getService(Fabric8FlinkKubeClient.java:334) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getInternalService(Fabric8FlinkKubeClient.java:246) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.run(KubernetesSessionCli.java:104) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.lambda$main$0(KubernetesSessionCli.java:185) >>>>>>> at >>>>>>> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.main(KubernetesSessionCli.java:185) >>>>>>> Caused by: java.net.SocketException: Broken pipe (Write failed) >>>>>>> at java.net.SocketOutputStream.socketWrite0(Native Method) >>>>>>> at >>>>>>> java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111) >>>>>>> at java.net.SocketOutputStream.write(SocketOutputStream.java:155) >>>>>>> at sun.security.ssl.OutputRecord.writeBuffer(OutputRecord.java:431) >>>>>>> at sun.security.ssl.OutputRecord.write(OutputRecord.java:417) >>>>>>> at >>>>>>> sun.security.ssl.SSLSocketImpl.writeRecordInternal(SSLSocketImpl.java:894) >>>>>>> at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:865) >>>>>>> at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:123) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okio.Okio$1.write(Okio.java:79) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okio.AsyncTimeout$1.write(AsyncTimeout.java:180) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okio.RealBufferedSink.flush(RealBufferedSink.java:224) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http2.Http2Writer.settings(Http2Writer.java:203) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http2.Http2Connection.start(Http2Connection.java:515) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http2.Http2Connection.start(Http2Connection.java:505) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RealConnection.startHttp2(RealConnection.java:298) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:287) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:168) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:257) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:135) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:114) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:126) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.utils.BackwardsCompatibilityInterceptor.intercept(BackwardsCompatibilityInterceptor.java:119) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.utils.ImpersonatorInterceptor.intercept(ImpersonatorInterceptor.java:68) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.utils.HttpClientUtils.lambda$createHttpClient$3(HttpClientUtils.java:112) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:254) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.RealCall.execute(RealCall.java:92) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:411) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:372) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:337) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:318) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleGet(BaseOperation.java:812) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:220) >>>>>>> ... 7 more >>>>>>> ------------------------------------------------------------ >>>>>>> The program finished with the following exception: >>>>>>> io.fabric8.kubernetes.client.KubernetesClientException: Operation: >>>>>>> [get] for kind: [Service] with name: >>>>>>> [flink-cluster-5c12bd50-a540-4614-96d0-549785a8bc62] in namespace: >>>>>>> [default] failed. >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:64) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:72) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:231) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:164) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getService(Fabric8FlinkKubeClient.java:334) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getInternalService(Fabric8FlinkKubeClient.java:246) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.run(KubernetesSessionCli.java:104) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.lambda$main$0(KubernetesSessionCli.java:185) >>>>>>> at >>>>>>> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.cli.KubernetesSessionCli.main(KubernetesSessionCli.java:185) >>>>>>> Caused by: java.net.SocketException: Broken pipe (Write failed) >>>>>>> at java.net.SocketOutputStream.socketWrite0(Native Method) >>>>>>> at >>>>>>> java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111) >>>>>>> at java.net.SocketOutputStream.write(SocketOutputStream.java:155) >>>>>>> at sun.security.ssl.OutputRecord.writeBuffer(OutputRecord.java:431) >>>>>>> at sun.security.ssl.OutputRecord.write(OutputRecord.java:417) >>>>>>> at >>>>>>> sun.security.ssl.SSLSocketImpl.writeRecordInternal(SSLSocketImpl.java:894) >>>>>>> at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:865) >>>>>>> at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:123) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okio.Okio$1.write(Okio.java:79) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okio.AsyncTimeout$1.write(AsyncTimeout.java:180) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okio.RealBufferedSink.flush(RealBufferedSink.java:224) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http2.Http2Writer.settings(Http2Writer.java:203) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http2.Http2Connection.start(Http2Connection.java:515) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http2.Http2Connection.start(Http2Connection.java:505) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RealConnection.startHttp2(RealConnection.java:298) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:287) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:168) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:257) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:135) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:114) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:126) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.utils.BackwardsCompatibilityInterceptor.intercept(BackwardsCompatibilityInterceptor.java:119) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.utils.ImpersonatorInterceptor.intercept(ImpersonatorInterceptor.java:68) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.utils.HttpClientUtils.lambda$createHttpClient$3(HttpClientUtils.java:112) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:254) >>>>>>> at >>>>>>> org.apache.flink.kubernetes.shadded.okhttp3.RealCall.execute(RealCall.java:92) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:411) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:372) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:337) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:318) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleGet(BaseOperation.java:812) >>>>>>> at >>>>>>> io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:220) >>>>>>> ... 7 more >>>>>> >>>>>> >>>>>> [1] >>>>>> https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/kubernetes.html >>>>>> [2] >>>>>> https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/native_kubernetes.html#start-flink-session >>>>>> >>>>>> Thanks, >>>>>> >>>>>> Dongwon >>>>>> >>>>>