flink-sql入es报错:Missing required options are document-type_org.apache.flink.table.api.validationexception: un-CSDN博客

网站介绍:文章浏览阅读1.6k次。我是在flink-sql创建es表的时候报的错,报错提示缺少对应的options,及document-type,我连忙去flink官方文档查找答案:https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/elasticsearch/#document-type从官方文档给出的连接参数可以看出document-type在es6中需要指定,而在es7中无需指定,原因大概是6.0版本及以前一个索引里可以创建_org.apache.flink.table.api.validationexception: unable to create a sink for