[FLINK-16465] Add more detailed instructions for TableSink

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Won't Fix
• Component/s: Documentation, Table SQL / API
• Assignee: Unassigned
• Reporter: hehuiyuan
• Created: 06/Mar/20 13:01
• Updated: 29/Apr/21 16:38
• Resolved: 29/Apr/21 16:38

Description

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

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)