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