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 <flin...@126.com>
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(...);
   }
 );
 

Reply via email to