You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by eg...@apache.org on 2022/12/09 00:23:55 UTC
[beam] branch master updated: ElasticsearchIO: Lower log level in flushBatch to avoid noisy log
This is an automated email from the ASF dual-hosted git repository.
egalpin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new d523a536a08 ElasticsearchIO: Lower log level in flushBatch to avoid noisy log
new ba38e41c702 Merge pull request #24604 from andthezhang/master
d523a536a08 is described below
commit d523a536a08c147c9085fb28137bb4418ac950bd
Author: andthezhang <hi...@gmail.com>
AuthorDate: Thu Dec 8 15:20:55 2022 -0800
ElasticsearchIO: Lower log level in flushBatch to avoid noisy log
---
.../main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java b/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java
index 67863218783..ddae2c22460 100644
--- a/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java
+++ b/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java
@@ -2460,7 +2460,7 @@ public class ElasticsearchIO {
return new ArrayList<>();
}
- LOG.info(
+ LOG.debug(
"ElasticsearchIO batch size: {}, batch size bytes: {}",
batch.size(),
currentBatchSizeBytes);