You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mh...@apache.org on 2018/10/27 21:19:51 UTC
asterixdb-bad git commit: [NO ISSUE][BAD] Coordinated Change For
Active Suspend Refactoring
Repository: asterixdb-bad
Updated Branches:
refs/heads/master eebcbe598 -> 64c2ad2ef
[NO ISSUE][BAD] Coordinated Change For Active Suspend Refactoring
Change-Id: Ifb40d76f208b7f42184f70b0e25d05f1875b4486
Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/64c2ad2e
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/64c2ad2e
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/64c2ad2e
Branch: refs/heads/master
Commit: 64c2ad2ef5cbda81c282e4d88843957ab68aa3e4
Parents: eebcbe5
Author: Murtadha Hubail <mu...@couchbase.com>
Authored: Thu Oct 18 09:53:39 2018 +0300
Committer: Murtadha Hubail <mu...@couchbase.com>
Committed: Thu Oct 18 09:53:39 2018 +0300
----------------------------------------------------------------------
.../asterix/bad/metadata/DeployedJobSpecEventListener.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/64c2ad2e/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
----------------------------------------------------------------------
diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
index 3ec2c43..70e780e 100644
--- a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
+++ b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
@@ -217,4 +217,9 @@ public class DeployedJobSpecEventListener implements IActiveEntityEventsListener
public int getRunningInstance() {
return runningInstance;
}
+
+ @Override
+ public synchronized boolean isSuspended() {
+ return state == ActivityState.SUSPENDED;
+ }
}