You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@gobblin.apache.org by "Joel Baranick (JIRA)" <ji...@apache.org> on 2017/11/09 18:09:00 UTC

[jira] [Created] (GOBBLIN-311) Gobblin AWS runs old jobs when cluster is restarted.

Joel Baranick created GOBBLIN-311:
-------------------------------------

             Summary: Gobblin AWS runs old jobs when cluster is restarted.
                 Key: GOBBLIN-311
                 URL: https://issues.apache.org/jira/browse/GOBBLIN-311
             Project: Apache Gobblin
          Issue Type: Bug
            Reporter: Joel Baranick
            Assignee: Hung Tran


On startup of my cluster, old jobs are still attempted. @htran1 said that they should be cleaned up in Standalone mode, but that does not seem compatible with running under AWS: [http://gobblin.readthedocs.io/en/latest/user-guide/Gobblin-Deployment/#standalone-architecture]
Also, if I enabled Standalone mode, then {{GobblinClusterManager.sendShutdownRequest()}} won't be called. Additionally, when enabling Standalone mode, GobblinClusterManager will call the following code, which doesn't seem right if I'm running under AWS:

{code:java}
 // In AWS / Yarn mode, the cluster Launcher takes care of setting up Helix cluster
/// .. but for Standalone mode, we go via this main() method, so setup the cluster here
if (isStandaloneClusterManager) {
    // Create Helix cluster and connect to it
    String zkConnectionString = config.getString(GobblinClusterConfigurationKeys.ZK_CONNECTION_STRING_KEY);
    String helixClusterName = config.getString(GobblinClusterConfigurationKeys.HELIX_CLUSTER_NAME_KEY);
    HelixUtils.createGobblinHelixCluster(zkConnectionString, helixClusterName, false);
    LOGGER.info("Created Helix cluster " + helixClusterName);
}
{code}

Thoughts?



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)