Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Won't Fix
-
None
-
None
-
None
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.
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)