[CARBONDATA-4058]create or insert data into the carbon table through …

…Hive throw NPE
apache · Dec 15, 2020 · 2339d75 · 2339d75
1 parent afb7626
commit 2339d75
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/integration/hive/src/main/scala/org/apache/carbondata/hive/CarbonHiveMetastoreListener.scala b/integration/hive/src/main/scala/org/apache/carbondata/hive/CarbonHiveMetastoreListener.scala
@@ -34,6 +34,7 @@ class CarbonHiveMetastoreListener(conf: Configuration) extends MetaStorePreEvent
         val table = preEventContext.asInstanceOf[PreCreateTableEvent].getTable
         val tableProps = table.getParameters
         if (tableProps != null
+          && tableProps.containsKey("spark.sql.sources.provider")
           && (tableProps.get("spark.sql.sources.provider") == "org.apache.spark.sql.CarbonSource"
           || tableProps.get("spark.sql.sources.provider").equalsIgnoreCase("carbondata"))) {
           val numSchemaParts = tableProps.get("spark.sql.sources.schema.numParts")
@@ -65,6 +66,7 @@ class CarbonHiveMetastoreListener(conf: Configuration) extends MetaStorePreEvent
         val table = preEventContext.asInstanceOf[PreAlterTableEvent].getNewTable
         val tableProps = table.getParameters
         if (tableProps != null
+          && tableProps.containsKey("spark.sql.sources.provider")
           && (tableProps.get("spark.sql.sources.provider") == "org.apache.spark.sql.CarbonSource"
           || tableProps.get("spark.sql.sources.provider").equalsIgnoreCase("carbondata"))) {
           val numSchemaParts = tableProps.get("spark.sql.sources.schema.numParts")