More precisely: Should the sink table `sql-sink` missed required version option.
> 在 2020年5月18日,21:13,Leonard Xu <xbjt...@gmail.com> 写道: > > Hi, > > Look likes you missed two required parameters: version and topic[1], you need > to add them for both source table and sink table. > > .connect( > new Kafka() > .version("0.11") // required: valid connector versions are > // "0.8", "0.9", "0.10", "0.11", and "universal" > .topic("...") // required: topic name from which the table is read > > Best, > Leonard Xu > [1]https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#kafka-connector > > <https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#kafka-connector> > > >> 在 2020年5月18日,12:28,Martin Frank Hansen <m...@berlingskemedia.dk >> <mailto:m...@berlingskemedia.dk>> 写道: >> >> connect(new Kafka() >> .version("universal") >