From fdf9d352f2ec5e489405fbdfe37a5cf102a1aea5 Mon Sep 17 00:00:00 2001 From: Gengliang Wang Date: Wed, 10 Jul 2019 17:52:41 +0800 Subject: [PATCH] fix --- .../java/org/apache/spark/sql/catalog/v2/Catalogs.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/catalog/v2/Catalogs.java b/sql/catalyst/src/main/java/org/apache/spark/sql/catalog/v2/Catalogs.java index 7511d947615a..f471a4e71cf4 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/catalog/v2/Catalogs.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/catalog/v2/Catalogs.java @@ -26,6 +26,7 @@ import java.lang.reflect.InvocationTargetException; import java.util.HashMap; import java.util.Map; +import java.util.NoSuchElementException; import java.util.regex.Matcher; import java.util.regex.Pattern; @@ -50,8 +51,10 @@ private Catalogs() { */ public static CatalogPlugin load(String name, SQLConf conf) throws CatalogNotFoundException, SparkException { - String pluginClassName = conf.getConfString("spark.sql.catalog." + name, null); - if (pluginClassName == null) { + String pluginClassName; + try { + pluginClassName = conf.getConfString("spark.sql.catalog." + name); + } catch (NoSuchElementException e){ throw new CatalogNotFoundException(String.format( "Catalog '%s' plugin class not found: spark.sql.catalog.%s is not defined", name, name)); }