calcite 添加架构无法评估 org.apache.calcite.sql.SqlJoin.toString()

如何解决calcite 添加架构无法评估 org.apache.calcite.sql.SqlJoin.toString()

我使用 cacite JDBC 连接 hive 并动态添加架构。想直接获取sql列元数据信息，不执行sql。 sql可以验证执行得到结果，但是无法获取sqljoin节点

            Class.forName("org.apache.calcite.jdbc.Driver");
            String driver = "org.apache.hive.jdbc.HiveDriver";
            Class.forName(driver);
            String url = "jdbc:hive2://192.168.8.225:10000/default";
            Properties info = new Properties();
            info.setProperty("caseSensitive","false");
            info.put("lex","BIG_QUERY");
            DataSource dataSource = JdbcSchema.dataSource(url,driver,null,null);
            Connection conn = DriverManager.getConnection("jdbc:calcite:",info);
            CalciteConnection calciteConnection = conn.unwrap(CalciteConnection.class);
            calciteConnection.setSchema("fdc");
            SchemaPlus rootSchema = calciteConnection.getRootSchema();
            Connection dataSourceConnection = dataSource.getConnection();
            DatabaseMetaData MetaData = dataSourceConnection.getMetaData();
            ResultSet schemas = MetaData.getSchemas();
            while(schemas.next()) {
                String schemasstring = schemas.getString("TABLE_SCHEM");
                //just set caseSensitive = false; unquotedCasing = Casing.UNCHANGED; quotedCasing = Casing.UNCHANGED;
                HiveJdbcSchema hiveJdbcSchema = HiveJdbcSchema.create(rootSchema,schemasstring,dataSource,schemasstring);
                rootSchema.add(schemasstring,hiveJdbcSchema);
            }

            sqlParser.Config builder = sqlParser.config().withQuotedCasing(Casing.TO_UPPER)
                    .withUnquotedCasing(Casing.TO_UPPER).withCaseSensitive(false)
                    .withQuoting(Quoting.BACK_TICK).withUnquotedCasing(Casing.UNCHANGED);

            final List<RelTraitDef> traitDefs = new ArrayList<RelTraitDef>();
            traitDefs.add(ConventionTraitDef.INSTANCE);
            traitDefs.add(RelCollationTraitDef.INSTANCE);

            final FrameworkConfig config = Frameworks.newConfigBuilder()
                    .defaultSchema(rootSchema.getSubSchema("default"))
                    .parserConfig(builder)
                    .operatorTable(sqlStdOperatorTable.instance())
                    .traitDefs(traitDefs)
                    .context(Contexts.EMPTY_CONTEXT)
                    .typeSystem(RelDataTypeSystem.DEFAULT)
                    .build();

            Planner planner = Frameworks.getPlanner(config);

            String sql = "select t1.* from fdc.t_fdc_base_visit_detail t1 join dim.t_dim3_cms_basic_doctor t2 on t1.doctor_id = t2.doctor_id limit 5";
            sqlNode originsqlNode = planner.parse(sql);
            Pair<sqlNode,RelDataType> sqlNodeRelDataTypePair = planner.validateAndGetType(originsqlNode);
            sqlNode sqlNode = sqlNodeRelDataTypePair.getKey();
            //Cannot evaluate org.apache.calcite.sql.sqlJoin.toString()
            sqlSelect sqlSelect = (sqlSelect) sqlNode;
            //sqlNode from = sqlSelect.getFrom();