public void checkConditionFieldsInTable(SqlNode conditionNode, JoinScope joinScope, AbstractSideTableInfo sideTableInfo) {
        List<SqlNode> sqlNodeList = Lists.newArrayList();
        ParseUtils.parseAnd(conditionNode, sqlNodeList);
        for (SqlNode sqlNode : sqlNodeList) {
            if (!SqlKind.COMPARISON.contains(sqlNode.getKind())) {
                throw new RuntimeException("It is not comparison operator.");
            }

            SqlNode leftNode = ((SqlBasicCall) sqlNode).getOperands()[0];
            SqlNode rightNode = ((SqlBasicCall) sqlNode).getOperands()[1];

            if (leftNode.getKind() == SqlKind.IDENTIFIER) {
                checkFieldInTable((SqlIdentifier) leftNode, joinScope, conditionNode, sideTableInfo);
            }

            if (rightNode.getKind() == SqlKind.IDENTIFIER) {
                checkFieldInTable((SqlIdentifier) rightNode, joinScope, conditionNode, sideTableInfo);
            }

        }
    }
check whether all table fields exist in join condition.
@param conditionNode
@param joinScope
core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java