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 >>>> >>>
