reuse sumEstimatedSize

elastic · Oct 24, 2018 · 980f1a5 · 980f1a5
1 parent 9925984
commit 980f1a5
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java
@@ -213,8 +213,7 @@ private synchronized void coordinateWrites() {
                     break;
                 }
             }
-            long opsSize = ops.stream().mapToLong(Translog.Operation::estimateSize).sum();
-            bufferSizeInBytes -= opsSize;
+            bufferSizeInBytes -= sumEstimatedSize;
             numConcurrentWrites++;
             LOGGER.trace("{}[{}] write [{}/{}] [{}]", params.getFollowShardId(), numConcurrentWrites, ops.get(0).seqNo(),
                 ops.get(ops.size() - 1).seqNo(), ops.size());