huxixiang commented on a change in pull request #16547:
URL: https://github.com/apache/flink/pull/16547#discussion_r680776600
##########
File path: docs/content.zh/docs/connectors/datastream/elasticsearch.md
##########
@@ -396,13 +374,13 @@ input.addSink(new ElasticsearchSink(
RequestIndexer indexer) {
if (ExceptionUtils.findThrowable(failure,
EsRejectedExecutionException.class).isPresent()) {
- // full queue; re-add document for indexing
+ // 队列已满；重新添加文档进行索引
Review comment:
Accepted, thanks.
##########
File path: docs/content.zh/docs/connectors/datastream/elasticsearch.md
##########
@@ -396,13 +374,13 @@ input.addSink(new ElasticsearchSink(
RequestIndexer indexer) {
if (ExceptionUtils.findThrowable(failure,
EsRejectedExecutionException.class).isPresent()) {
- // full queue; re-add document for indexing
+ // 队列已满；重新添加文档进行索引
indexer.add(action)
} else if (ExceptionUtils.findThrowable(failure,
ElasticsearchParseException.class).isPresent()) {
- // malformed document; simply drop request without failing sink
+ // 文档格式错误；简单地删除请求避免 sink 失败
Review comment:
Accepted, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
