hehuiyuan created FLINK-13756: --------------------------------- Summary: Modify Code Annotations for findAndCreateTableSource in TableFactoryUtil Key: FLINK-13756 URL: https://issues.apache.org/jira/browse/FLINK-13756 Project: Flink Issue Type: Wish Components: Table SQL / API Reporter: hehuiyuan
/** * Returns a *table sink* matching the \{@link org.apache.flink.table.catalog.CatalogTable}. */ public static <T> TableSource<T> findAndCreateTableSource(CatalogTable table) { return findAndCreateTableSource(table.toProperties()); } Hi , this method `findAndCreateTableSource` is used for returning `TableSource` , but the annotation is *` Returns a table sink`* -- This message was sent by Atlassian JIRA (v7.6.14#76016)