Reset error delay on success

gerashegalov · Oct 9, 2015 · 378e21e · 378e21e
1 parent 75a1bd4
commit 378e21e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/presto-main/src/main/java/com/facebook/presto/operator/HttpPageBufferClient.java b/presto-main/src/main/java/com/facebook/presto/operator/HttpPageBufferClient.java
@@ -312,7 +312,7 @@ public void onSuccess(PagesResponse result)
  }
  future = null;
  lastUpdate = DateTime.now();
-
+ errorDelayMillis = 0;
  }
  requestsCompleted.incrementAndGet();
  clientCallback.requestComplete(HttpPageBufferClient.this);
@@ -350,6 +350,7 @@ public void onSuccess(@Nullable StatusResponse result)
  closed = true;
  future = null;
  lastUpdate = DateTime.now();
+ errorDelayMillis = 0;
  }
  requestsCompleted.incrementAndGet();
  clientCallback.clientFinished(HttpPageBufferClient.this);