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相比多了个 中括号,并且采用 ',' 分割名字功空间,这是为什么
