Mailing-List: contact yarn-issues-help@hadoop.apache.org; run by ezmlm
Precedence: bulk
Reply-To: yarn-issues@hadoop.apache.org
Date: Fri, 8 May 2015 21:35:02 +0000 (UTC)
From: "Spandan Dutta (JIRA)" <jira@apache.org>
To: yarn-issues@hadoop.apache.org
Message-ID: <JIRA.12828499.1431120892000.57609.1431120902655@Atlassian.JIRA>
In-Reply-To: <JIRA.12828499.1431120892000@Atlassian.JIRA>
References: <JIRA.12828499.1431120892000@Atlassian.JIRA>
 <JIRA.12828499.1431120892997@arcas>
Subject: [jira] [Created] (YARN-3608) Apps submitted to MiniYarnCluster
 always stay in ACCEPTED state.
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

Spandan Dutta created YARN-3608:
-----------------------------------

             Summary: Apps submitted to MiniYarnCluster always stay in ACCEPTED state.
                 Key: YARN-3608
                 URL: https://issues.apache.org/jira/browse/YARN-3608
             Project: Hadoop YARN
          Issue Type: Bug
          Components: applications
    Affects Versions: 2.6.0
            Reporter: Spandan Dutta


So I adapted a test case to submit a yarn app to a MiniYarnCluster and wait for it to reach running state. Turns out that the app gets stuck in "ACCEPTED" state. 
{noformat}
 @Test
  public void testGetAllQueues() throws IOException, YarnException, InterruptedException {
    MiniYARNCluster cluster = new MiniYARNCluster("testMRAMTokens", 1, 1, 1);
    YarnClient rmClient = null;
    try {
      cluster.init(new YarnConfiguration());
      cluster.start();
      final Configuration yarnConf = cluster.getConfig();
      rmClient = YarnClient.createYarnClient();
      rmClient.init(yarnConf);
      rmClient.start();
      YarnClientApplication newApp = rmClient.createApplication();

      ApplicationId appId = newApp.getNewApplicationResponse().getApplicationId();

      // Create launch context for app master
      ApplicationSubmissionContext appContext
          = Records.newRecord(ApplicationSubmissionContext.class);

      // set the application id
      appContext.setApplicationId(appId);

      // set the application name
      appContext.setApplicationName("test");

      // Set up the container launch context for the application master
      ContainerLaunchContext amContainer
          = Records.newRecord(ContainerLaunchContext.class);

      appContext.setAMContainerSpec(amContainer);
      appContext.setResource(Resource.newInstance(1024, 1));

      // Submit the application to the applications manager
      rmClient.submitApplication(appContext);
      ApplicationReport applicationReport =
          rmClient.getApplicationReport(appContext.getApplicationId());

      int timeout = 10;
      while(timeout > 0 && applicationReport.getYarnApplicationState() !=
          YarnApplicationState.RUNNING) {
        Thread.sleep(5 * 1000);
        timeout--;
      }
      Assert.assertTrue(timeout != 0);
      Assert.assertTrue(applicationReport.getYarnApplicationState()
          == YarnApplicationState.RUNNING);
      List<QueueInfo> queues = rmClient.getAllQueues();
      Assert.assertNotNull(queues);
      Assert.assertTrue(!queues.isEmpty());
      QueueInfo queue = queues.get(0);
      List<ApplicationReport> queueApplications = queue.getApplications();
      Assert.assertFalse(queueApplications.isEmpty());
    } catch (YarnException e) {
      Assert.assertTrue(e.getMessage().contains("Failed to submit"));
    } finally {
      if (rmClient != null) {
        rmClient.stop();
      }
      cluster.stop();
    }
  }
{noformat}


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)