abdullah alamoudi has submitted this change and it was merged. Change subject: ASTERIXDB-1175 Ensure Feed Central Manager Starts ......................................................................
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 <[email protected]> Tested-by: Jenkins <[email protected]> --- M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java 1 file changed, 5 insertions(+), 0 deletions(-) Approvals: Yingyi Bu: Looks good to me, approved Jenkins: Verified 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.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 @@ private Server webServer; private Server jsonAPIServer; private Server feedServer; + private ICentralFeedManager centralFeedManager; private static IAsterixStateProxy proxy; private ICCApplicationContext appCtx; @@ -100,6 +103,8 @@ feedServer.start(); ExternalLibraryBootstrap.setUpExternaLibraries(false); + centralFeedManager = CentralFeedManager.getInstance(); + centralFeedManager.start(); AsterixGlobalRecoveryManager.INSTANCE = new AsterixGlobalRecoveryManager( (HyracksConnection) getNewHyracksClientConnection()); -- To view, visit https://asterix-gerrit.ics.uci.edu/502 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: Ifeaf7f70864a0efad38f3f2627b97ebdff06a0c1 Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Yingyi Bu <[email protected]> Gerrit-Reviewer: abdullah alamoudi <[email protected]>
