(gravitino) branch main updated: [#7218] improvement(spark-connector): Add null check for partition column names (#7254)

[jmclean]

This is an automated email from the ASF dual-hosted git repository.

jmclean pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/main by this push:
     new 98e94c80c4 [#7218] improvement(spark-connector): Add null check for 
partition column names (#7254)
98e94c80c4 is described below

commit 98e94c80c4bb9a80f88110a3e615a56368dbb826
Author: Kyle Lin <168957924+kylelin0...@users.noreply.github.com>
AuthorDate: Wed May 28 07:27:11 2025 +0800

    [#7218] improvement(spark-connector): Add null check for partition column 
names (#7254)
    
    ### What changes were proposed in this pull request?
    
    Added a null check for the names parameter in `getHivePartitionName` to
    avoid potential NPE.
    
    ### Why are the changes needed?
    
    Fixes #7218
    
    ### Does this PR introduce any user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    - Ran `./gradlew clean build`
---
 .../gravitino/spark/connector/utils/HiveGravitinoOperationOperator.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/utils/HiveGravitinoOperationOperator.java
 
b/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/utils/HiveGravitinoOperationOperator.java
index a88cdfbf70..85af6800d6 100644
--- 
a/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/utils/HiveGravitinoOperationOperator.java
+++ 
b/spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/utils/HiveGravitinoOperationOperator.java
@@ -19,6 +19,7 @@
 
 package org.apache.gravitino.spark.connector.utils;
 
+import com.google.common.base.Preconditions;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -145,6 +146,7 @@ public class HiveGravitinoOperationOperator {
   private @NotNull String getHivePartitionName(
       String[] names, InternalRow ident, StructType partitionSchema) {
     StringBuilder partitionName = new StringBuilder();
+    Preconditions.checkArgument(names != null, "Partition column names must 
not be null");
     for (int i = 0; i < names.length; i++) {
       StructField structField = partitionSchema.apply(i);
       DataType dataType = structField.dataType();