[ https://issues.apache.org/jira/browse/FLINK-13756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909683#comment-16909683 ]
Jark Wu commented on FLINK-13756: --------------------------------- Thank you [~hehuiyuan]. I assigned it to you. > 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 > Assignee: hehuiyuan > Priority: Minor > > > /** > * 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)