Merge pull request #616 from tgroh/tsan_smallness

Reduce Size of UnboundedReadDeduplicatorTest
GoogleCloudPlatform · Nov 22, 2017 · 85556d0 · 85556d0
2 parents a9e25ab + 12f3495
commit 85556d0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...t/java/com/google/cloud/dataflow/sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java b/...t/java/com/google/cloud/dataflow/sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java
@@ -60,7 +60,7 @@ public void cachedIdDeduplicatorMultithreaded() throws InterruptedException {
     byte[] id = new byte[] {-1, 2, 4, 22};
     UnboundedReadDeduplicator dedupper = CachedIdDeduplicator.create();
     final CountDownLatch startSignal = new CountDownLatch(1);
-    int numThreads = 1000;
+    int numThreads = 10;
     final CountDownLatch readyLatch = new CountDownLatch(numThreads);
     final CountDownLatch finishLine = new CountDownLatch(numThreads);