fixup! Reduce Size of UnboundedReadDeduplicatorTest

GoogleCloudPlatform · Nov 22, 2017 · 12f3495 · 12f3495
1 parent b27a221
commit 12f3495
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 = 50;
+    int numThreads = 10;
     final CountDownLatch readyLatch = new CountDownLatch(numThreads);
     final CountDownLatch finishLine = new CountDownLatch(numThreads);