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