Skip to content

Commit 2339d75

Browse files
committed
[CARBONDATA-4058]create or insert data into the carbon table through Hive throw NPE
1 parent afb7626 commit 2339d75

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

integration/hive/src/main/scala/org/apache/carbondata/hive/CarbonHiveMetastoreListener.scala

+2
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ class CarbonHiveMetastoreListener(conf: Configuration) extends MetaStorePreEvent
3434
val table = preEventContext.asInstanceOf[PreCreateTableEvent].getTable
3535
val tableProps = table.getParameters
3636
if (tableProps != null
37+
&& tableProps.containsKey("spark.sql.sources.provider")
3738
&& (tableProps.get("spark.sql.sources.provider") == "org.apache.spark.sql.CarbonSource"
3839
|| tableProps.get("spark.sql.sources.provider").equalsIgnoreCase("carbondata"))) {
3940
val numSchemaParts = tableProps.get("spark.sql.sources.schema.numParts")
@@ -65,6 +66,7 @@ class CarbonHiveMetastoreListener(conf: Configuration) extends MetaStorePreEvent
6566
val table = preEventContext.asInstanceOf[PreAlterTableEvent].getNewTable
6667
val tableProps = table.getParameters
6768
if (tableProps != null
69+
&& tableProps.containsKey("spark.sql.sources.provider")
6870
&& (tableProps.get("spark.sql.sources.provider") == "org.apache.spark.sql.CarbonSource"
6971
|| tableProps.get("spark.sql.sources.provider").equalsIgnoreCase("carbondata"))) {
7072
val numSchemaParts = tableProps.get("spark.sql.sources.schema.numParts")

0 commit comments

Comments
 (0)