[Minor][Spark] Fix Spark comparison bug (#318)

apache · Jan 10, 2024 · 955b3a5 · 955b3a5
1 parent c68f430
commit 955b3a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spark/src/main/scala/com/alibaba/graphar/util/Utils.scala b/spark/src/main/scala/com/alibaba/graphar/util/Utils.scala
@@ -127,7 +127,7 @@ object Utils {
             val isPrimary: Boolean =
               if (
                 (primaryKeys(key) == "" && properties
-                  .size() == 0) || field.name == primaryKeys
+                  .size() == 0) || field.name.equals(primaryKeys(key))
               ) true
               else false
             property.setIs_primary(isPrimary)