public void launch ( ) throws IOException , InterruptedException { this . eventBus . register ( this ) ; // Create Helix cluster and connect to it HelixUtils . createGobblinHelixCluster ( this . zkConnectionString , this . helixClusterName , false ) ; LOGGER . info ( "Created Helix cluster " + this . helixClusterName ) ; connectHelixManager ( ) ; // Core logic to launch cluster this . clusterId = getClusterId ( ) ; // TODO: Add cluster monitoring countDownLatch . await ( ) ; }
Launch a new Gobblin cluster on AWS .