| commit | 70a7d5882f89f42b8653d8a4d9ebda37ace902c6 | [log] [tgz] |
|---|---|---|
| author | Murtadha Hubail <mhubail@apache.org> | Thu Dec 03 20:32:04 2020 +0300 |
| committer | Murtadha Hubail <mhubail@apache.org> | Fri Dec 04 18:32:06 2020 +0000 |
| tree | 3c125ae32083fc0c86f5f6c0339efca441fa68d7 | |
| parent | 6fd8ab35b6244793db9eaa8fdb4754a0d3e1ac1c [diff] |
[NO ISSUE][ING] Set active entity as suspended on suspension success - user model changes: no - storage format changes: no - interface changes: no Details: - When an active entity is suspended successfully, set the suspended flag regardless of the state. Change-Id: I42f8d92e1719103d94aa07801b987466e2c1a11d Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/9143 Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Till Westmann <tillw@apache.org>
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 0f5dec7..c90cde0 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
@@ -609,6 +609,7 @@ suspendTask.get(); LOGGER.log(level, "waiting for state to become SUSPENDED or TEMPORARILY_FAILED"); subscriber.sync(); + suspended = true; } catch (Exception e) { synchronized (this) { if (LOGGER.isErrorEnabled()) {