diff --git standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java index 8a826d2ac1..ffc86071b8 100644 --- standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -4605,10 +4605,10 @@ private boolean constraintNameAlreadyExists(MTable table, String constraintName constraintName = normalizeIdentifier(constraintName); constraintExistsQuery = pm.newQuery(MConstraint.class, "parentTable == parentTableP && constraintName == constraintNameP"); - constraintExistsQuery.declareParameters("java.lang.Long parentTableP, java.lang.String constraintNameP"); + constraintExistsQuery.declareParameters("MTable parentTableP, java.lang.String constraintNameP"); constraintExistsQuery.setUnique(true); constraintExistsQuery.setResult("constraintName"); - constraintNameIfExists = (String) constraintExistsQuery.executeWithArray(table.getId(), constraintName); + constraintNameIfExists = (String) constraintExistsQuery.executeWithArray(table, constraintName); commited = commitTransaction(); } finally { rollbackAndCleanup(commited, constraintExistsQuery);