[fix-33011][core]builtin function error filter

Author: simenliuxing

core/src/main/java/com/dtstack/flink/sql/side/JoinNodeDealer.java

@@ -47,13 +47,12 @@
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.flink.api.java.tuple.Tuple2;
-import org.apache.flink.table.functions.BuiltInFunctionDefinitions;
 
 import java.util.List;
 import java.util.Map;
 import java.util.Queue;
 import java.util.Set;
-import java.util.stream.Collectors;
+import java.util.Arrays;
 
 import static org.apache.calcite.sql.SqlKind.*;
 
@@ -74,6 +73,9 @@ public class JoinNodeDealer {
 
     private FlinkPlanner flinkPlanner = new FlinkPlanner();
 
+    // 内置无参函数的临时解决方法，防止被误判为表的字段
+    private List<String> builtInFunctionNames = Arrays.asList("LOCALTIMESTAMP", "LOCALTIME", "CURRENT_TIMESTAMP", "CURRENT_TIME", "CURRENT_DATE", "PI");
+
     public JoinNodeDealer(SideSQLParser sideSQLParser){
         this.sideSQLParser = sideSQLParser;
     }
@@ -611,11 +613,6 @@ private void extractSelectField(SqlNode selectNode,
             SqlIdentifier sqlIdentifier = (SqlIdentifier) selectNode;
 
             if (sqlIdentifier.names.size() == 1) {
-                List<String> builtInFunctionNames = BuiltInFunctionDefinitions
-                        .getDefinitions()
-                        .stream()
-                        .map(e -> e.getName().toUpperCase())
-                        .collect(Collectors.toList());
                 if (builtInFunctionNames.contains(sqlIdentifier.toString().toUpperCase())) {
                     return;
                 } else {