From 4955a2d8d664084743c745a49c1b865ce4f8fdd9 Mon Sep 17 00:00:00 2001
From: liyong072 <903912591@qq.com>
Date: Tue, 15 Dec 2020 17:14:34 +0800
Subject: [PATCH] [CARBONDATA-4058] create or insert data into the carbon table
 through Hive throw NPE

---
 .../apache/carbondata/hive/CarbonHiveMetastoreListener.scala    | 2 ++
 1 file changed, 2 insertions(+)

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
index c8e268b4b3f..68ca164ef5a 100644
--- 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")