回复：sinktable更新部分字段问题

Tue, 26 May 2020 22:08:25 -0700 

Hi, Leonard xu

谢谢你的回复
connector当前是支持两种模式的。但是更新的时候，select的字段数量必须等于es索引的全部字段。我这边想要根据主键更新索引的部分字段


| |
naturalfree
|
|
邮箱：[email protected]
|

签名由 网易邮箱大师 定制

在2020年05月22日 23:29，Leonard Xu 写道：
Hi，naturalfree

Flink SQL 里es sink 是支持Append mode和upsert mode的[1]，upsert mode下支持按主键更新的，你可以看看。


Best,
Leonard Xu
[1] 
https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/connect.html#elasticsearch-connector
 
<https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/connect.html#elasticsearch-connector&gt;

> 在 2020年5月20日，16:07，naturalfree <[email protected]> 写道：
>
> 现在有一个es索引，想通过flink sql根据主键更新部分字段。不知是否有可行方案
>
>
> | |
> naturalfree
> |
> |
> 邮箱：[email protected]
> |
>
> 签名由 网易邮箱大师 定制

回复