From f6bd4fb4a9f598b7679efc034b135d6a2d6ef260 Mon Sep 17 00:00:00 2001 From: weizijun Date: Tue, 12 Jul 2022 16:15:31 +0800 Subject: [PATCH] revert bulk failed log --- .../xpack/rollup/v2/RollupShardIndexer.java | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/x-pack/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/v2/RollupShardIndexer.java b/x-pack/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/v2/RollupShardIndexer.java index e2417e525b6c8..6b3836d49228c 100644 --- a/x-pack/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/v2/RollupShardIndexer.java +++ b/x-pack/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/v2/RollupShardIndexer.java @@ -182,13 +182,7 @@ public void afterBulk(long executionId, BulkRequest request, BulkResponse respon ) ); numFailed.addAndGet(failures.size()); - logger.info( - "Shard [{}] failed to populate rollup index, failures summery: failed count: [{}], failed sample: [{}]", - indexShard.shardId(), - failures.size(), - failures.values().iterator().next() - ); - logger.trace("Shard [{}] failed to populate rollup index. Failures: [{}]", indexShard.shardId(), failures); + logger.error("Shard [{}] failed to populate rollup index. Failures: [{}]", indexShard.shardId(), failures); } } @@ -197,7 +191,7 @@ public void afterBulk(long executionId, BulkRequest request, Throwable failure) if (failure != null) { long items = request.numberOfActions(); numFailed.addAndGet(items); - logger.info(() -> format("Shard [%s] failed to populate rollup index.", indexShard.shardId()), failure); + logger.error(() -> format("Shard [%s] failed to populate rollup index.", indexShard.shardId()), failure); } } };