asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amo...@apache.org
Subject incubator-asterixdb git commit: ASTERIXDB-1175 Ensure Feed Central Manager Starts
Date Thu, 19 Nov 2015 01:58:43 GMT
Repository: incubator-asterixdb
Updated Branches:
  refs/heads/master 754539621 -> 40d7581f3


ASTERIXDB-1175 Ensure Feed Central Manager Starts

This change fixes the connection refused exception that shows
up when asterix is started. The reason for this connection refused
is that the feed central manager was not started and local feed
managers try to connect to it.

Change-Id: Ifeaf7f70864a0efad38f3f2627b97ebdff06a0c1
Reviewed-on: https://asterix-gerrit.ics.uci.edu/502
Reviewed-by: Yingyi Bu <buyingyi@gmail.com>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>


Project: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/commit/40d7581f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/tree/40d7581f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/diff/40d7581f

Branch: refs/heads/master
Commit: 40d7581f3092b2f5f53b82f713aef3d68614495a
Parents: 7545396
Author: Abdullah Alamoudi <bamousaa@gmail.com>
Authored: Wed Nov 18 14:24:43 2015 -0800
Committer: abdullah alamoudi <bamousaa@gmail.com>
Committed: Wed Nov 18 17:53:37 2015 -0800

----------------------------------------------------------------------
 .../asterix/hyracks/bootstrap/CCApplicationEntryPoint.java      | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/40d7581f/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
----------------------------------------------------------------------
diff --git a/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
b/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
index 24d2283..80ce5ea 100644
--- a/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
+++ b/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
@@ -37,9 +37,11 @@ import org.apache.asterix.common.api.IClusterManagementWork.ClusterState;
 import org.apache.asterix.common.config.AsterixExternalProperties;
 import org.apache.asterix.common.config.AsterixMetadataProperties;
 import org.apache.asterix.common.config.AsterixReplicationProperties;
+import org.apache.asterix.common.feeds.api.ICentralFeedManager;
 import org.apache.asterix.compiler.provider.AqlCompilationProvider;
 import org.apache.asterix.compiler.provider.SqlppCompilationProvider;
 import org.apache.asterix.event.service.ILookupService;
+import org.apache.asterix.feeds.CentralFeedManager;
 import org.apache.asterix.feeds.FeedLifecycleListener;
 import org.apache.asterix.metadata.MetadataManager;
 import org.apache.asterix.metadata.api.IAsterixStateProxy;
@@ -66,6 +68,7 @@ public class CCApplicationEntryPoint implements ICCApplicationEntryPoint
{
     private Server webServer;
     private Server jsonAPIServer;
     private Server feedServer;
+    private ICentralFeedManager centralFeedManager;
 
     private static IAsterixStateProxy proxy;
     private ICCApplicationContext appCtx;
@@ -100,6 +103,8 @@ public class CCApplicationEntryPoint implements ICCApplicationEntryPoint
{
         feedServer.start();
 
         ExternalLibraryBootstrap.setUpExternaLibraries(false);
+        centralFeedManager = CentralFeedManager.getInstance();
+        centralFeedManager.start();
 
         AsterixGlobalRecoveryManager.INSTANCE = new AsterixGlobalRecoveryManager(
                 (HyracksConnection) getNewHyracksClientConnection());


Mime
View raw message