Updated Branches: refs/heads/flume-1.3.0 f5f199f38 -> 81effe2e3
FLUME-1524. Fix flaky MonitoredCounterGroup test. (Mike Percy via Hari Shreedharan) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/81effe2e Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/81effe2e Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/81effe2e Branch: refs/heads/flume-1.3.0 Commit: 81effe2e3e1e6741d468c9de949e8e0329e90131 Parents: f5f199f Author: Hari Shreedharan <[email protected]> Authored: Wed Aug 29 15:08:47 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Wed Aug 29 15:10:13 2012 -0700 ---------------------------------------------------------------------- .../instrumentation/TestMonitoredCounterGroup.java | 9 +++++++++ 1 files changed, 9 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/81effe2e/flume-ng-core/src/test/java/org/apache/flume/instrumentation/TestMonitoredCounterGroup.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/test/java/org/apache/flume/instrumentation/TestMonitoredCounterGroup.java b/flume-ng-core/src/test/java/org/apache/flume/instrumentation/TestMonitoredCounterGroup.java index 1b8447a..0a730e9 100644 --- a/flume-ng-core/src/test/java/org/apache/flume/instrumentation/TestMonitoredCounterGroup.java +++ b/flume-ng-core/src/test/java/org/apache/flume/instrumentation/TestMonitoredCounterGroup.java @@ -157,6 +157,9 @@ public class TestMonitoredCounterGroup { assertSkCounterState(on, connCreated, connClosed, connFailed, batchEmpty, batchUnderflow, batchComplete, eventDrainAttempt, eventDrainSuccess); + // give start time a chance to increment + Thread.sleep(5L); + skc.start(); Assert.assertTrue("StartTime", getStartTime(on) != 0L); Assert.assertTrue("StartTime", getStartTime(on) > start1); @@ -219,6 +222,9 @@ public class TestMonitoredCounterGroup { assertChCounterState(on, numChannelSize, numEventPutAttempt, numEventTakeAttempt, numEventPutSuccess, numEventTakeSuccess); + // give start time a chance to increment + Thread.sleep(5L); + chc.start(); Assert.assertTrue("StartTime", getStartTime(on) != 0L); Assert.assertTrue("StartTime", getStartTime(on) > start1); @@ -280,6 +286,9 @@ public class TestMonitoredCounterGroup { numAppendReceived, numAppendAccepted, numAppendBatchReceived, numAppendBatchAccepted); + // give start time a chance to increment + Thread.sleep(5L); + srcc.start(); Assert.assertTrue("StartTime", getStartTime(on) != 0L); Assert.assertTrue("StartTime", getStartTime(on) > start1);
