>From Michael Blow <[email protected]>:
Michael Blow has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20391?usp=email )
Change subject: [NO ISSUE][*DB][APP] Allow active setRunning to throw HDE
......................................................................
[NO ISSUE][*DB][APP] Allow active setRunning to throw HDE
Ext-ref: MB-68573
Change-Id: Ifdf8a55ea4290257492ba021396def3dd3b204d7
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/RecoveryTask.java
2 files changed, 3 insertions(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/91/20391/1
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 6df2e3c..9ec1d71 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
@@ -522,7 +522,7 @@
protected abstract void doResume(MetadataProvider metadataProvider) throws
HyracksDataException;
- protected abstract void setRunning(MetadataProvider metadataProvider,
boolean running);
+ protected abstract void setRunning(MetadataProvider metadataProvider,
boolean running) throws HyracksDataException;
@Override
public final synchronized void stop(MetadataProvider metadataProvider)
diff --git
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/RecoveryTask.java
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/RecoveryTask.java
index 39c1125..082f805 100644
---
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/RecoveryTask.java
+++
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/RecoveryTask.java
@@ -118,7 +118,8 @@
}
}
- protected Void doRecover(IRetryPolicy policy) throws AlgebricksException,
InterruptedException {
+ protected Void doRecover(IRetryPolicy policy)
+ throws AlgebricksException, InterruptedException,
HyracksDataException {
LOGGER.log(level, "Actual Recovery task has started");
Exception failure;
long prevSuspendCount;
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20391?usp=email
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings?usp=email
Gerrit-MessageType: newchange
Gerrit-Project: asterixdb
Gerrit-Branch: phoenix
Gerrit-Change-Id: Ifdf8a55ea4290257492ba021396def3dd3b204d7
Gerrit-Change-Number: 20391
Gerrit-PatchSet: 1
Gerrit-Owner: Michael Blow <[email protected]>
