Hi Ada, 这应该就是一个实现上的失误:
1. source的名字是calcite的`TableScan#explainTerms`里面实现的,用的是`explainTerms(pw).item("table", this.table.getQualifiedName())` 2. sink里的名字是flink里的`Sink#explainTerms`实现的,用的是`.explainTerms(pw).item("table", tableIdentifier.asSummaryString())` yidan zhao <hinobl...@gmail.com> 于2021年9月30日周四 上午11:43写道: > 我猜哈,是因为source支持多张表。比如多个表union支持select的情况。 > > Ada Luna <gfen...@gmail.com> 于2021年9月29日周三 下午6:02写道: > > > Source: TableSourceScan(table=[[default_catalog, default_database, > > ods_k]], fields=[id, name]) > > Sink: Sink(table=[default_catalog.default_database.ads_k], fields=[id, > > name]) > > Sink: Sink(table=[default_catalog.default_database.ads_k2], fields=[id, > > name])) > > > > > > TableSourceScan 和 Sink相比多了个 中括号,并且采用 ',' 分割名字功空间,这是为什么 > > > -- Best, Benchao Li