revert bulk failed log

weizijun · Jul 12, 2022 · f6bd4fb · f6bd4fb
1 parent b3c0f68
commit f6bd4fb
Showing 1 changed file with 2 additions and 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
@@ -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);
                 }
             }
         };