You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/03/06 13:02:00 UTC
[jira] [Created] (FLINK-16465) Add more detailed instructions for
TableSink
hehuiyuan created FLINK-16465:
---------------------------------
Summary: 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
Reporter: hehuiyuan
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)