Return-Path: X-Original-To: apmail-hadoop-yarn-issues-archive@minotaur.apache.org Delivered-To: apmail-hadoop-yarn-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 337FD184A9 for ; Fri, 8 May 2015 22:46:02 +0000 (UTC) Received: (qmail 57010 invoked by uid 500); 8 May 2015 22:46:01 -0000 Delivered-To: apmail-hadoop-yarn-issues-archive@hadoop.apache.org Received: (qmail 56979 invoked by uid 500); 8 May 2015 22:46:01 -0000 Mailing-List: contact yarn-issues-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: yarn-issues@hadoop.apache.org Delivered-To: mailing list yarn-issues@hadoop.apache.org Received: (qmail 56841 invoked by uid 99); 8 May 2015 22:46:01 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 May 2015 22:46:01 +0000 Date: Fri, 8 May 2015 22:46:01 +0000 (UTC) From: "Spandan Dutta (JIRA)" To: yarn-issues@hadoop.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (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 X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/YARN-3608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14535802#comment-14535802 ] Spandan Dutta commented on YARN-3608: ------------------------------------- I think this is a bug at the MiniYarnCluster implementation part. The app gets stuck for a MiniYarnCluster. > 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 queues = rmClient.getAllQueues(); > Assert.assertNotNull(queues); > Assert.assertTrue(!queues.isEmpty()); > QueueInfo queue = queues.get(0); > List 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)