Remove early acks after abort again

1 files changed, 1 insertions, 11 deletions

diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
index 9d1b1b966aa..a102e8fffd4 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
@@ -594,7 +594,6 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler {
         private final AtomicLong documentsWritten = new AtomicLong();
         private final AtomicLong documentsFlushed = new AtomicLong();
         private final AtomicLong documentsAcked = new AtomicLong();
-        private final AtomicBoolean ackAll = new AtomicBoolean();
         private boolean documentsDone = false;
         private boolean first = true;
         private ContentChannel channel;
@@ -731,13 +730,8 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler {
             }
         }
 
-        void ackAll() {
-            ackAll.set(true);
-            ackDocuments();
-        }
-
         void ackDocuments() {
-            while (documentsAcked.incrementAndGet() <= documentsFlushed.get() + FLUSH_SIZE || ackAll.get()) {
+            while (documentsAcked.incrementAndGet() <= documentsFlushed.get() + FLUSH_SIZE) {
                 CompletionHandler ack = acks.poll();
                 if (ack != null)
                     ack.completed();
@@ -1275,10 +1269,6 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler {
                     });
 
                 }
-                @Override public void abort() {
-                    super.abort();
-                    response.ackAll();
-                }
             };
             if (parameters.getRemoteDataHandler() == null) {
                 parameters.setLocalDataHandler(new VisitorDataHandler() {