You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cn...@apache.org on 2013/07/02 07:32:18 UTC
svn commit: r1498786 - in
/hadoop/common/trunk/hadoop-common-project/hadoop-common: CHANGES.txt
src/test/java/org/apache/hadoop/ipc/TestRPC.java
Author: cnauroth
Date: Tue Jul 2 05:32:17 2013
New Revision: 1498786
URL: http://svn.apache.org/r1498786
Log:
HADOOP-9678. TestRPC#testStopsAllThreads intermittently fails on Windows. Contributed by Ivan Mitic.
Modified:
hadoop/common/trunk/hadoop-common-project/hadoop-common/CHANGES.txt
hadoop/common/trunk/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java
Modified: hadoop/common/trunk/hadoop-common-project/hadoop-common/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-common-project/hadoop-common/CHANGES.txt?rev=1498786&r1=1498785&r2=1498786&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-common-project/hadoop-common/CHANGES.txt (original)
+++ hadoop/common/trunk/hadoop-common-project/hadoop-common/CHANGES.txt Tue Jul 2 05:32:17 2013
@@ -781,6 +781,9 @@ Release 2.1.0-beta - 2013-07-02
HADOOP-9264. Port change to use Java untar API on Windows from
branch-1-win to trunk. (Chris Nauroth via suresh)
+ HADOOP-9678. TestRPC#testStopsAllThreads intermittently fails on Windows.
+ (Ivan Mitic via cnauroth)
+
HADOOP-9665. Fixed BlockDecompressorStream#decompress to return -1 rather
than throw EOF at end of file. (Zhijie Shen via acmurthy)
Modified: hadoop/common/trunk/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java?rev=1498786&r1=1498785&r2=1498786&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java (original)
+++ hadoop/common/trunk/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java Tue Jul 2 05:32:17 2013
@@ -781,7 +781,17 @@ public class TestRPC {
.setNumHandlers(5).setVerbose(true).build();
server.start();
try {
- int threadsRunning = countThreads("Server$Listener$Reader");
+ // Wait for at least one reader thread to start
+ int threadsRunning = 0;
+ long totalSleepTime = 0;
+ do {
+ totalSleepTime += 10;
+ Thread.sleep(10);
+ threadsRunning = countThreads("Server$Listener$Reader");
+ } while (threadsRunning == 0 && totalSleepTime < 5000);
+
+ // Validate that at least one thread started (we didn't timeout)
+ threadsRunning = countThreads("Server$Listener$Reader");
assertTrue(threadsRunning > 0);
} finally {
server.stop();