Repository: incubator-distributedlog Updated Branches: refs/heads/master 58ba6f47c -> cf9bcd2a8
DL-155: fix flaky TestAsyncReaderLock#testReaderLockMultiReadersScenario Ran the case with changed patch 30 times, all are passed; and it'll fail w/o patch Author: xieliang <xieliang...@gmail.com> Reviewers: Sijie Guo <si...@apache.org> Closes #88 from xieliang/DL-155 Project: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/commit/cf9bcd2a Tree: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/tree/cf9bcd2a Diff: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/diff/cf9bcd2a Branch: refs/heads/master Commit: cf9bcd2a89bd87ecdc7e2b803ad3f16bdaea61ea Parents: 58ba6f4 Author: xieliang <xieliang...@gmail.com> Authored: Tue Dec 27 09:05:00 2016 -0800 Committer: Sijie Guo <sij...@twitter.com> Committed: Tue Dec 27 09:05:00 2016 -0800 ---------------------------------------------------------------------- .../java/com/twitter/distributedlog/TestAsyncReaderLock.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/cf9bcd2a/distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderLock.java ---------------------------------------------------------------------- diff --git a/distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderLock.java b/distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderLock.java index ccc2b6b..47cabba 100644 --- a/distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderLock.java +++ b/distributedlog-core/src/test/java/com/twitter/distributedlog/TestAsyncReaderLock.java @@ -421,10 +421,10 @@ public class TestAsyncReaderLock extends TestDistributedLogBase { URI uri = createDLMURI("/" + name); ensureURICreated(uri); - // Force immediate flush to make dlsn counting easy. DistributedLogConfiguration localConf = new DistributedLogConfiguration(); localConf.addConfiguration(conf); - localConf.setImmediateFlushEnabled(true); + localConf.setImmediateFlushEnabled(false); + localConf.setPeriodicFlushFrequencyMilliSeconds(60 * 1000); localConf.setOutputBufferSize(0); // Otherwise, we won't be able to run scheduled threads for readahead when we're in a callback. localConf.setNumWorkerThreads(2);
