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(...); } );