[nereids] pull up join from union all rule

Author: zhongjian.xzj

fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PullUpJoinFromUnionAll.java

@@ -344,23 +344,33 @@ private boolean checkJoinConditionOnPk(LogicalJoin joinRoot, LogicalCatalogRelat
     }
 
     private Set<String> getPkInfoFromConstraint(LogicalCatalogRelation table) {
-        for (Map.Entry<String, Constraint> constraintMap : table.getTable().getConstraintsMap().entrySet()) {
-            Constraint constraint = constraintMap.getValue();
-            if (constraint instanceof PrimaryKeyConstraint) {
-                return ((PrimaryKeyConstraint) constraint).getPrimaryKeyNames();
+        table.getTable().readLock();
+        try {
+            for (Map.Entry<String, Constraint> constraintMap : table.getTable().getConstraintsMap().entrySet()) {
+                Constraint constraint = constraintMap.getValue();
+                if (constraint instanceof PrimaryKeyConstraint) {
+                    return ((PrimaryKeyConstraint) constraint).getPrimaryKeyNames();
+                }
             }
+            return null;
+        } finally {
+            table.getTable().readUnlock();
         }
-        return null;
     }
 
     private Set<String> getUkInfoFromConstraint(LogicalCatalogRelation table) {
-        for (Map.Entry<String, Constraint> constraintMap : table.getTable().getConstraintsMap().entrySet()) {
-            Constraint constraint = constraintMap.getValue();
-            if (constraint instanceof UniqueConstraint) {
-                return ((UniqueConstraint) constraint).getUniqueColumnNames();
+        table.getTable().readLock();
+        try {
+            for (Map.Entry<String, Constraint> constraintMap : table.getTable().getConstraintsMap().entrySet()) {
+                Constraint constraint = constraintMap.getValue();
+                if (constraint instanceof UniqueConstraint) {
+                    return ((UniqueConstraint) constraint).getUniqueColumnNames();
+                }
             }
+            return null;
+        } finally {
+            table.getTable().readUnlock();
         }
-        return null;
     }
 
     private boolean checkJoinRoot(LogicalJoin joinRoot) {