From 12f34951b1710599489e6e53c3243cc2c5db724c Mon Sep 17 00:00:00 2001
From: Thomas Groh <tgroh@users.noreply.github.com>
Date: Wed, 22 Nov 2017 09:53:33 -0800
Subject: [PATCH] fixup! Reduce Size of UnboundedReadDeduplicatorTest

---
 .../sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdk/src/test/java/com/google/cloud/dataflow/sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java b/sdk/src/test/java/com/google/cloud/dataflow/sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java
index 9fdb27203f..3b5efb5c6b 100644
--- a/sdk/src/test/java/com/google/cloud/dataflow/sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java
+++ b/sdk/src/test/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);