维表join npe问题

Author: simenliuxing

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

@@ -360,8 +360,14 @@ private SqlNode replaceOrderByTableName(SqlNode orderNode, String tableAlias) {
     private SqlNode replaceNodeInfo(SqlNode groupNode, HashBasedTable<String, String, String> mappingTable, String tableAlias){
         if(groupNode.getKind() == IDENTIFIER){
             SqlIdentifier sqlIdentifier = (SqlIdentifier) groupNode;
+            if(sqlIdentifier.names.size() == 1){
+                return sqlIdentifier;
+            }
             String mappingFieldName = mappingTable.get(sqlIdentifier.getComponent(0).getSimple(), sqlIdentifier.getComponent(1).getSimple());
 
+            if(mappingFieldName == null){
+                throw new RuntimeException("can't find mapping fieldName:" + sqlIdentifier.toString() );
+            }
             sqlIdentifier = sqlIdentifier.setName(0, tableAlias);
             return sqlIdentifier.setName(1, mappingFieldName);
         }else if(groupNode instanceof  SqlBasicCall){