This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new dc78e66 [Hotfix][doc] Fix typo in java code demo of ES stream
connector page for release-1.14 (#18934)
dc78e66 is described below
commit dc78e662f6e456fa86f5c0b946c9be7ade0e976b
Author: Roc Marshal <[email protected]>
AuthorDate: Tue Mar 1 16:56:03 2022 +0800
[Hotfix][doc] Fix typo in java code demo of ES stream connector page for
release-1.14 (#18934)
---
docs/content.zh/docs/connectors/datastream/elasticsearch.md | 8 ++++----
docs/content/docs/connectors/datastream/elasticsearch.md | 8 ++++----
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/docs/content.zh/docs/connectors/datastream/elasticsearch.md
b/docs/content.zh/docs/connectors/datastream/elasticsearch.md
index 0638573..26090b2 100644
--- a/docs/content.zh/docs/connectors/datastream/elasticsearch.md
+++ b/docs/content.zh/docs/connectors/datastream/elasticsearch.md
@@ -166,10 +166,10 @@ esSinkBuilder.setBulkFlushMaxActions(1);
// 为内部创建的 REST 客户端提供一个自定义配置信息的 RestClientFactory
esSinkBuilder.setRestClientFactory(
restClientBuilder -> {
- restClientBuilder.setDefaultHeaders(...)
- restClientBuilder.setMaxRetryTimeoutMillis(...)
- restClientBuilder.setPathPrefix(...)
- restClientBuilder.setHttpClientConfigCallback(...)
+ restClientBuilder.setDefaultHeaders(...);
+ restClientBuilder.setMaxRetryTimeoutMillis(...);
+ restClientBuilder.setPathPrefix(...);
+ restClientBuilder.setHttpClientConfigCallback(...);
}
);
diff --git a/docs/content/docs/connectors/datastream/elasticsearch.md
b/docs/content/docs/connectors/datastream/elasticsearch.md
index 30ffd8a..767d0bf 100644
--- a/docs/content/docs/connectors/datastream/elasticsearch.md
+++ b/docs/content/docs/connectors/datastream/elasticsearch.md
@@ -172,10 +172,10 @@ esSinkBuilder.setBulkFlushMaxActions(1);
// provide a RestClientFactory for custom configuration on the internally
created REST client
esSinkBuilder.setRestClientFactory(
restClientBuilder -> {
- restClientBuilder.setDefaultHeaders(...)
- restClientBuilder.setMaxRetryTimeoutMillis(...)
- restClientBuilder.setPathPrefix(...)
- restClientBuilder.setHttpClientConfigCallback(...)
+ restClientBuilder.setDefaultHeaders(...);
+ restClientBuilder.setMaxRetryTimeoutMillis(...);
+ restClientBuilder.setPathPrefix(...);
+ restClientBuilder.setHttpClientConfigCallback(...);
}
);