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