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 dfc38eb..1928bce 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 @@ -443,8 +443,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()); + KeyProvider keyProvider = miniDFSCluster.getNameNode().getNamesystem().getProvider(); + if (keyProvider != null) { + miniDFSCluster.getFileSystem().getClient().setKeyProvider(keyProvider); + } cluster = new MiniDFSShim(miniDFSCluster); return cluster;