(hive) branch master updated: HIVE-28971: DirectSql for msck repair is failing because of wrong casting (#5827)

[dengzh]

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

dengzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new de994e5c556 HIVE-28971: DirectSql for msck repair is failing because 
of wrong casting (#5827)
de994e5c556 is described below

commit de994e5c556930d1761601a61d6941c69fa9e153
Author: Raghav Aggarwal <raghavaggarwal03...@gmail.com>
AuthorDate: Mon Jun 2 07:01:10 2025 +0530

    HIVE-28971: DirectSql for msck repair is failing because of wrong casting 
(#5827)
---
 .../java/org/apache/hadoop/hive/metastore/DirectSqlInsertPart.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/DirectSqlInsertPart.java
 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/DirectSqlInsertPart.java
index 8e93f9c8042..5ac6e082a4e 100644
--- 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/DirectSqlInsertPart.java
+++ 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/DirectSqlInsertPart.java
@@ -28,6 +28,7 @@
 import java.util.Map;
 
 import javax.jdo.PersistenceManager;
+import javax.jdo.identity.LongIdentity;
 
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.hadoop.hive.metastore.api.MetaException;
@@ -42,7 +43,6 @@
 import org.apache.hadoop.hive.metastore.model.MStringList;
 import org.datanucleus.ExecutionContext;
 import org.datanucleus.api.jdo.JDOPersistenceManager;
-import org.datanucleus.identity.DatastoreId;
 import org.datanucleus.metadata.AbstractClassMetaData;
 import org.datanucleus.metadata.AbstractMemberMetaData;
 import org.datanucleus.metadata.IdentityType;
@@ -755,7 +755,7 @@ public void addPartitions(List<MPartition> parts, 
List<List<MPartitionPrivilege>
       serdeIdToSerDeInfo.put(serDeId, sd.getSerDeInfo());
 
       Long cdId;
-      DatastoreId storeId = (DatastoreId) pm.getObjectId(sd.getCD());
+      LongIdentity storeId = (LongIdentity) pm.getObjectId(sd.getCD());
       if (storeId == null) {
         cdId = getDataStoreId(MColumnDescriptor.class);
         cdIdToColumnDescriptor.put(cdId, sd.getCD());