[jira] [Updated] (FLINK-16465) Add more detailed instructions for TableSink

["Robert Metzger (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-16465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger updated FLINK-16465:
-----------------------------------
    Component/s: Table SQL / API

> Add more detailed instructions for TableSink
> --------------------------------------------
>
>                 Key: FLINK-16465
>                 URL: https://issues.apache.org/jira/browse/FLINK-16465
>             Project: Flink
>          Issue Type: Wish
>          Components: Documentation, Table SQL / API
>            Reporter: hehuiyuan
>            Priority: Minor
>
> That has a error when I define a UpserStreamTableSink without getTableSchem method or getFieldsNames/getFields methods.
> Some instructions are added that may be better.
> [https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html#upsertstreamtablesink]
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.TableException: Table sink does not implement a table schema.
> at org.apache.flink.table.sinks.TableSink.getTableSchema(TableSink.java:75)
> at org.apache.flink.table.api.internal.TableEnvironmentImpl.registerTableSink(TableEnvironmentImpl.java:215)
> at com.jd.flink.sql.writer.console.ConsoleUpsertWriter.initWriter(ConsoleUpsertWriter.java:40)
> at com.jd.flink.sql.writer.Writer.registWriter(Writer.java:33)
> at com.jd.flink.sql.test.MainClassTest_hhy.main(MainClassTest_hhy.java:222)
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)