This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch es-bulk
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/es-bulk by this push:
     new 95698cf58f Fix words.
95698cf58f is described below

commit 95698cf58ff5341efff90a8885081d4a5f1b4b7f
Author: Wu Sheng <[email protected]>
AuthorDate: Thu Dec 8 20:01:01 2022 +0800

    Fix words.
---
 docs/en/changes/changes.md                                              | 2 +-
 .../org/apache/skywalking/library/elasticsearch/bulk/BulkProcessor.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/en/changes/changes.md b/docs/en/changes/changes.md
index e311e153fc..d4641ac348 100644
--- a/docs/en/changes/changes.md
+++ b/docs/en/changes/changes.md
@@ -33,7 +33,7 @@
 * Remove the dependency of `refresh_interval` of ElasticSearch indices from 
`elasticsearch/flushInterval` config. Now,
   it uses `core/persistentPeriod` + 5s as `refresh_interval` for all indices 
instead.
 * Change `elasticsearch/flushInterval` to 5s(was 15s).
-* Optimize `flushInterval` of ElasticSearch BulkProcessor to avoid extra 
periodical flush in continuous bulk stream. 
+* Optimize `flushInterval` of ElasticSearch BulkProcessor to avoid extra 
periodical flush in the continuous bulk streams. 
 
 #### UI
 
diff --git 
a/oap-server/server-library/library-elasticsearch-client/src/main/java/org/apache/skywalking/library/elasticsearch/bulk/BulkProcessor.java
 
b/oap-server/server-library/library-elasticsearch-client/src/main/java/org/apache/skywalking/library/elasticsearch/bulk/BulkProcessor.java
index eae56c39b5..c80540e079 100644
--- 
a/oap-server/server-library/library-elasticsearch-client/src/main/java/org/apache/skywalking/library/elasticsearch/bulk/BulkProcessor.java
+++ 
b/oap-server/server-library/library-elasticsearch-client/src/main/java/org/apache/skywalking/library/elasticsearch/bulk/BulkProcessor.java
@@ -109,7 +109,7 @@ public final class BulkProcessor {
     private void doPeriodicalFlush() {
         if (System.currentTimeMillis() - lastFlushTS > flushInternalInMillis / 
2) {
             // Run periodical flush if there is no `flushIfNeeded` executed in 
the second half of the flush period.
-            // Otherwise, wait for next round. By default, last 2 seconds of 
5s period.
+            // Otherwise, wait for the next round. By default, the last 2 
seconds of the 5s period.
             // This could avoid periodical flush running among 
bulks(controlled by bulkActions).
             flush();
         }

Reply via email to