Author: shawkins Date: 2011-02-25 15:40:17 -0500 (Fri, 25 Feb 2011) New Revision: 2948 Modified: trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java Log: ensuring that timing issues will not affect unit test Modified: trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java =================================================================== --- trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java 2011-02-25 05:57:52 UTC (rev 2947) +++ trunk/engine/src/test/java/org/teiid/dqp/internal/process/TestDQPCore.java 2011-02-25 20:40:17 UTC (rev 2948) @@ -210,7 +210,7 @@ Thread.sleep(100); } assertEquals(ThreadState.IDLE, item.getThreadState()); - assertEquals(46, item.resultsBuffer.getRowCount()); + assertTrue(item.resultsBuffer.getManagedRowCount() < 44); //pull the rest of the results for (int j = 0; j < 48; j++) { item = core.getRequestWorkItem(DQPWorkContext.getWorkContext().getRequestID(reqMsg.getExecutionId()));