Repository: asterixdb-bad Updated Branches: refs/heads/master 83f6d53b0 -> 3292476e4
Replace byte value with enum for active events Change-Id: Ib9e93fc704ede2a6d2990d62ed7f9bf052cb4be2 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/3292476e Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/3292476e Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/3292476e Branch: refs/heads/master Commit: 3292476e415aa00f662c75717ee2ae074a052ec1 Parents: 83f6d53 Author: Abdullah Alamoudi <[email protected]> Authored: Wed Aug 9 16:37:12 2017 -0700 Committer: Abdullah Alamoudi <[email protected]> Committed: Wed Aug 9 16:37:12 2017 -0700 ---------------------------------------------------------------------- .../apache/asterix/bad/metadata/PrecompiledJobEventListener.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/3292476e/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/PrecompiledJobEventListener.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/PrecompiledJobEventListener.java b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/PrecompiledJobEventListener.java index 8e0cf5f..b2d60fe 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/PrecompiledJobEventListener.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/PrecompiledJobEventListener.java @@ -30,6 +30,7 @@ import org.apache.asterix.active.EntityId; import org.apache.asterix.active.IActiveEntityEventSubscriber; import org.apache.asterix.active.IActiveEntityEventsListener; import org.apache.asterix.active.message.ActivePartitionMessage; +import org.apache.asterix.active.message.ActivePartitionMessage.Event; import org.apache.asterix.app.result.ResultReader; import org.apache.asterix.common.dataflow.ICcApplicationContext; import org.apache.asterix.common.metadata.IDataset; @@ -92,7 +93,7 @@ public class PrecompiledJobEventListener implements IActiveEntityEventsListener } protected synchronized void handle(ActivePartitionMessage message) { - if (message.getEvent() == ActivePartitionMessage.ACTIVE_RUNTIME_REGISTERED) { + if (message.getEvent() == Event.RUNTIME_REGISTERED) { numRegistered++; if (numRegistered == locations.getLocations().length) { state = ActivityState.RUNNING;
