This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
The following commit(s) were added to refs/heads/main by this push:
new c80d39b [FLINK-37265][docs] Document of python elasticsearch
connector exeample has a little mistake
c80d39b is described below
commit c80d39b94520f439dd0d582e11cca122dd1090da
Author: Milesian111 <[email protected]>
AuthorDate: Mon Feb 10 15:24:57 2025 +0800
[FLINK-37265][docs] Document of python elasticsearch connector exeample has
a little mistake
---
docs/content.zh/docs/connectors/datastream/elasticsearch.md | 2 +-
docs/content/docs/connectors/datastream/elasticsearch.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/connectors/datastream/elasticsearch.md
b/docs/content.zh/docs/connectors/datastream/elasticsearch.md
index 98c193c..b659d36 100644
--- a/docs/content.zh/docs/connectors/datastream/elasticsearch.md
+++ b/docs/content.zh/docs/connectors/datastream/elasticsearch.md
@@ -251,7 +251,7 @@ input = ...
# 下面的 set_bulk_flush_max_actions 使 sink 在接收每个元素之后立即提交，否则这些元素将被缓存起来
es7_sink = Elasticsearch7SinkBuilder() \
.set_bulk_flush_max_actions(1) \
- .set_emitter(ElasticsearchEmitter.static('foo', 'id')) \
+ .set_emitter(ElasticsearchEmitter.static_index('foo', 'id')) \
.set_hosts(['localhost:9200']) \
.build()
diff --git a/docs/content/docs/connectors/datastream/elasticsearch.md
b/docs/content/docs/connectors/datastream/elasticsearch.md
index 9086090..78b213c 100644
--- a/docs/content/docs/connectors/datastream/elasticsearch.md
+++ b/docs/content/docs/connectors/datastream/elasticsearch.md
@@ -251,7 +251,7 @@ input = ...
# The set_bulk_flush_max_actions instructs the sink to emit after every
element, otherwise they would be buffered
es7_sink = Elasticsearch7SinkBuilder() \
.set_bulk_flush_max_actions(1) \
- .set_emitter(ElasticsearchEmitter.static('foo', 'id')) \
+ .set_emitter(ElasticsearchEmitter.static_index('foo', 'id')) \
.set_hosts(['localhost:9200']) \
.build()
