From b27a221a440c25fb459175724d979519bb79d8a9 Mon Sep 17 00:00:00 2001 From: Thomas Groh Date: Mon, 13 Nov 2017 21:01:56 -0800 Subject: [PATCH 1/2] Reduce Size of UnboundedReadDeduplicatorTest Fixes slowdowns causing timeouts in certain environments. --- .../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 8685920151..9fdb27203f 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 = 1000; + int numThreads = 50; final CountDownLatch readyLatch = new CountDownLatch(numThreads); final CountDownLatch finishLine = new CountDownLatch(numThreads); From 12f34951b1710599489e6e53c3243cc2c5db724c Mon Sep 17 00:00:00 2001 From: Thomas Groh Date: Wed, 22 Nov 2017 09:53:33 -0800 Subject: [PATCH 2/2] 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);