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)