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