fix

Signed-off-by: srlch <[email protected]>
StarRocks · Nov 13, 2024 · 1c8fcb3 · 1c8fcb3
1 parent 59415d3
commit 1c8fcb3
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/sql/analyzer/BackupRestoreAnalyzer.java b/fe/fe-core/src/main/java/com/starrocks/sql/analyzer/BackupRestoreAnalyzer.java
@@ -165,12 +165,12 @@ public Void visitBackupStatement(BackupStmt backupStmt, ConnectContext context)
                     String fnName = entry.getKey();
                     List<Function> fns = entry.getValue();
 
-                    boolean notExisted = fnRefs.stream()
-                                         .allMatch(fnRef -> fnRef.getFnName().getFunction().equalsIgnoreCase(fnName));
-
-                    if (notExisted) {
-                        fnRefs.add(new FunctionRef(fns));
+                    if (fnRefs.stream().anyMatch(x -> x.getFunctions().get(0)
+                                                 .getFunctionName().getFunction().equalsIgnoreCase(fnName))) {
+                        continue;
                     }
+
+                    fnRefs.add(new FunctionRef(fns));
                 }
             } else {
                 backupStmt.getFnRefs().stream().forEach(x -> x.analyzeForBackup(database));