Hello,


When I’m trying to set below options to spark-submit command on k8s Master
getting below error in spark-driver pod logs



--conf spark.executor.extraJavaOptions=" -Dhttps.proxyHost=myhost
-Dhttps.proxyPort=8099 -Dhttp.useproxy=true -Dhttps.protocols=TLSv1.2" \

--conf spark.driver.extraJavaOptions="--Dhttps.proxyHost=myhost
-Dhttps.proxyPort=8099 -Dhttp.useproxy=true -Dhttps.protocols=TLSv1.2" \



But when I tried to set these extraJavaoptions as system.properties in the
spark application jar everything works fine.



2018-06-11 21:26:28 ERROR SparkContext:91 - Error initializing SparkContext.

org.apache.spark.SparkException: External scheduler cannot be instantiated

                at
org.apache.spark.SparkContext$.org$apache$spark$SparkContext$$createTaskScheduler(SparkContext.scala:2747)

                at
org.apache.spark.SparkContext.<init>(SparkContext.scala:492)

                at
org.apache.spark.SparkContext$.getOrCreate(SparkContext.scala:2486)

                at
org.apache.spark.sql.SparkSession$Builder$$anonfun$7.apply(SparkSession.scala:930)

                at
org.apache.spark.sql.SparkSession$Builder$$anonfun$7.apply(SparkSession.scala:921)

                at scala.Option.getOrElse(Option.scala:121)

                at
org.apache.spark.sql.SparkSession$Builder.getOrCreate(SparkSession.scala:921)

Caused by: io.fabric8.kubernetes.client.KubernetesClientException:
Operation: [get]  for kind: [Pod]  with name:
[test-657e2f715ada3f91ae32c588aa178f63-driver]  in namespace: [test]
failed.

at
io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:62)

                at
io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:71)

                at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:228)

                at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:184)

                at
org.apache.spark.scheduler.cluster.k8s.KubernetesClusterSchedulerBackend.<init>(KubernetesClusterSchedulerBackend.scala:70)

                at
org.apache.spark.scheduler.cluster.k8s.KubernetesClusterManager.createSchedulerBackend(KubernetesClusterManager.scala:120)

                at
org.apache.spark.SparkContext$.org$apache$spark$SparkContext$$createTaskScheduler(SparkContext.scala:2741)

                ... 12 more

Caused by: javax.net.ssl.SSLHandshakeException:
sun.security.validator.ValidatorException: PKIX path building failed:
sun.security.provider.certpath.SunCertPathBuilderException: unable to find
valid certification path to requested target

                at sun.security.ssl.Alerts.getSSLException(Alerts.java:192)

                at
sun.security.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1959)

                at sun.security.ssl.Handshaker.fatalSE(Handshaker.java:302)

                at sun.security.ssl.Handshaker.fatalSE(Handshaker.java:296)

                at
sun.security.ssl.ClientHandshaker.serverCertificate(ClientHandshaker.java:1514)

                at
sun.security.ssl.ClientHandshaker.processMessage(ClientHandshaker.java:216)

                at
sun.security.ssl.Handshaker.processLoop(Handshaker.java:1026)

                at
sun.security.ssl.Handshaker.process_record(Handshaker.java:961)

at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:1072)

                at
sun.security.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1385)

                at
sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1413)

                at
sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1397)

                at
okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:281)

                at
okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:251)

                at
okhttp3.internal.connection.RealConnection.connect(RealConnection.java:151)

                at
okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:195)

                at
okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:121)

                at
okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:100)

                at
okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)

                at
okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)

                at
okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)

                at
okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:120)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)

                at
io.fabric8.kubernetes.client.utils.HttpClientUtils$2.intercept(HttpClientUtils.java:93)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)

                at
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)

                at
okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:185)

                at okhttp3.RealCall.execute(RealCall.java:69)

                at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:377)

at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:343)

                at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:312)

                at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:295)

                at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleGet(BaseOperation.java:783)

                at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:217)

                ... 16 more

Caused by: sun.security.validator.ValidatorException: *PKIX path building
failed:* sun.security.provider.certpath.SunCertPathBuilderException: unable
to find valid certification path to requested target

                at
sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:397)

                at
sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:302)

                at
sun.security.validator.Validator.validate(Validator.java:260)

                at
sun.security.ssl.X509TrustManagerImpl.validate(X509TrustManagerImpl.java:324)

                at
sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:229)





Thanks,

Purna

------------------------------

The information contained in this e-mail is confidential and/or proprietary
to Capital One and/or its affiliates and may only be used solely in
performance of work or services for Capital One. The information
transmitted herewith is intended only for use by the individual or entity
to which it is addressed. If the reader of this message is not the intended
recipient, you are hereby notified that any review, retransmission,
dissemination, distribution, copying or other use of, or taking of any
action in reliance upon this information is strictly prohibited. If you
have received this communication in error, please contact the sender and
delete the material from your computer.

Reply via email to