diff --git a/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java b/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java index 8c865ee..91d5e8f 100644 --- a/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java +++ b/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java @@ -39,6 +39,7 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.crypto.key.KeyProvider; import org.apache.hadoop.crypto.key.KeyProvider.Options; +import org.apache.hadoop.crypto.key.KeyProviderCryptoExtension; import org.apache.hadoop.crypto.key.KeyProviderFactory; import org.apache.hadoop.fs.BlockLocation; import org.apache.hadoop.fs.DefaultFileAccess; @@ -495,8 +496,10 @@ public void setupConfiguration(Configuration conf) { // Need to set the client's KeyProvider to the NN's for JKS, // else the updates do not get flushed properly - miniDFSCluster.getFileSystem().getClient().setKeyProvider( - miniDFSCluster.getNameNode().getNamesystem().getProvider()); + KeyProviderCryptoExtension keyProvider = miniDFSCluster.getNameNode().getNamesystem().getProvider(); + if (keyProvider != null) { + miniDFSCluster.getFileSystem().getClient().setKeyProvider(keyProvider); + } cluster = new MiniDFSShim(miniDFSCluster); return cluster;