diff options
| author | woj-i <wojciechindyk@gmail.com> | 2015-12-01 11:05:45 -0800 |
|---|---|---|
| committer | Marcelo Vanzin <vanzin@cloudera.com> | 2015-12-01 11:05:45 -0800 |
| commit | 6a8cf80cc8ef435ec46138fa57325bda5d68f3ce (patch) | |
| tree | a1534cac8bbd7b12c81492f309e9d9e3706c1386 /core | |
| parent | 0a7bca2da04aefff16f2513ec27a92e69ceb77f6 (diff) | |
| download | spark-6a8cf80cc8ef435ec46138fa57325bda5d68f3ce.tar.gz spark-6a8cf80cc8ef435ec46138fa57325bda5d68f3ce.tar.bz2 spark-6a8cf80cc8ef435ec46138fa57325bda5d68f3ce.zip | |
[SPARK-11821] Propagate Kerberos keytab for all environments
andrewor14 the same PR as in branch 1.5
harishreedharan
Author: woj-i <wojciechindyk@gmail.com>
Closes #9859 from woj-i/master.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala index 2e912b59af..52d3ab34c1 100644 --- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala +++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala @@ -545,6 +545,10 @@ object SparkSubmit { if (args.isPython) { sysProps.put("spark.yarn.isPython", "true") } + } + + // assure a keytab is available from any place in a JVM + if (clusterManager == YARN || clusterManager == LOCAL) { if (args.principal != null) { require(args.keytab != null, "Keytab must be specified when principal is specified") if (!new File(args.keytab).exists()) { |