hadoop-mapreduce-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nitin Pawar <nitinpawar...@gmail.com>
Subject Re: Progress indicator should not be negative.
Date Mon, 21 Jul 2014 09:57:35 GMT
Smita,

Any chance you can print the value of containers waiting and total before
the exception.

From
http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.4.1/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java?view=markup

around line 207, it looks like your progress value is getting negative.


On Mon, Jul 21, 2014 at 2:19 PM, Smita Deshpande <
smita.deshpande@cumulus-systems.com> wrote:

>  Hi Guys,
>
> Can anyone please provide some suggestions/solutions on it?
>
>
>
> Thanks,
>
> Smita
>
>
>
> *From:* Smita Deshpande
> *Sent:* Thursday, July 17, 2014 11:41 AM
> *To:* 'user@hadoop.apache.org'
> *Subject:* Progress indicator should not be negative.
>
>
>
> Hi,
>
>                 I am running the distributed shell example of YARN on
> apache Hadoop 2.4.0.
>
> I have implemented getProgress method in my ApplicationMaster as follows
>
>
>
> *public* *float* getProgress() {
>
>       // set progress to deliver to RM on next heartbeat
>
>        *float* progress = 0;
>
>        *try*{
>
>               progress = (*float*) numCompletedContainers.get() /
> numTotalContainers.get();
>
>        } *catch*(Exception _ex) {
>
>               _ex.printStackTrace();
>
>        }
>
>        *return* progress;
>
> }
>
>
>
> While shutting down the application I get following excpetion
>
>
>
> - Interrupted while waiting for queue
>
> java.lang.InterruptedException
>
>         at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2017)
>
>         at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2052)
>
>         at
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
>
>         at
> org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl$CallbackHandlerThread.run(AMRMClientAsyncImpl.java:275)
>
>
>
>
> When I restart my application I get following error
>
>
>
> java.lang.IllegalArgumentException: Progress indicator should not be
> negative
>
>
>
> Because of this, my ApplicationMaster is launched in another container.
> This exception is coming all the time in above scenario.
>
>
>
> Can you suggest me what is going wrong?
>
>
>
> Thanks,
>
> Smita
>
>
>



-- 
Nitin Pawar

Mime
View raw message