commit 5de12d01c019e609992845e6fc5a2d0a9b2cb9e9
author Abdullah Alamoudi <bamousaa@gmail.com> Thu Aug 02 17:05:43 2018 -0700
committer abdullah alamoudi <bamousaa@gmail.com> Thu Aug 02 20:13:45 2018 -0700
tree 4b71b369f7e9f4d746f8d6b3781a6923a1589826
parent a7094732bd76095ac39e826e2da61b3a4261e21b

[NO ISSUE][ING] Increase timeout for stopping ingestion

- user model changes: no
- storage format changes: no
- interface changes: no

Details:
- To allow systems under high load enough time to push
  accumulated data to storage, we increased the default
  timeout for stopping active entities to 5 minutes.

Change-Id: I3e590b1c7fdc0eb9be34d82b4b2ac1b2a2eef515
Reviewed-on: https://asterix-gerrit.ics.uci.edu/2841
Reviewed-by: Murtadha Hubail <mhubail@apache.org>
Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java

diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
index 345080cc..b5432c5 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
@@ -75,8 +75,8 @@
             ActivityState.STARTING, ActivityState.STOPPING, ActivityState.RECOVERING, ActivityState.CANCELLING);
     private static final String DEFAULT_ACTIVE_STATS = "{\"Stats\":\"N/A\"}";
     // TODO: Make configurable https://issues.apache.org/jira/browse/ASTERIXDB-2065
-    protected static final long STOP_MESSAGE_TIMEOUT = 2L;
-    protected static final long SUSPEND_MESSAGE_TIMEOUT = 5L;
+    protected static final long STOP_MESSAGE_TIMEOUT = 5L;
+    protected static final long SUSPEND_MESSAGE_TIMEOUT = 10L;
     protected static final TimeUnit TIMEOUT_UNIT = TimeUnit.MINUTES;
     protected final IClusterStateManager clusterStateManager;
     protected final ActiveNotificationHandler handler;