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")
> 

Reply via email to