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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)