From 9443646e72b51a0cc4b94e98a495159942929c73 Mon Sep 17 00:00:00 2001 From: mcheah Date: Fri, 7 Dec 2018 13:23:40 -0800 Subject: [PATCH] Check for non empty files. --- core/src/main/scala/org/apache/spark/SecurityManager.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/SecurityManager.scala b/core/src/main/scala/org/apache/spark/SecurityManager.scala index 4da89198ccd9a..cb3a51e3d31a4 100644 --- a/core/src/main/scala/org/apache/spark/SecurityManager.scala +++ b/core/src/main/scala/org/apache/spark/SecurityManager.scala @@ -397,7 +397,9 @@ private[spark] class SecurityManager( case k8sRegex() => val secretFile = new File(secretFilePath) require(secretFile.isFile, s"No file found containing the secret key at $secretFilePath.") - Base64.getEncoder.encodeToString(Files.readAllBytes(secretFile.toPath)) + val base64Key = Base64.getEncoder.encodeToString(Files.readAllBytes(secretFile.toPath)) + require(!base64Key.isEmpty, s"Secret key from file located at $secretFilePath is empty.") + base64Key case _ => throw new IllegalArgumentException( "Secret keys provided via files is only allowed in Kubernetes mode.")