Skip to content
This repository was archived by the owner on Nov 11, 2022. It is now read-only.

Commit b27a221

Browse files
committed
Reduce Size of UnboundedReadDeduplicatorTest
Fixes slowdowns causing timeouts in certain environments.
1 parent a9e25ab commit b27a221

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sdk/src/test/java/com/google/cloud/dataflow/sdk/runners/inprocess/UnboundedReadDeduplicatorTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public void cachedIdDeduplicatorMultithreaded() throws InterruptedException {
6060
byte[] id = new byte[] {-1, 2, 4, 22};
6161
UnboundedReadDeduplicator dedupper = CachedIdDeduplicator.create();
6262
final CountDownLatch startSignal = new CountDownLatch(1);
63-
int numThreads = 1000;
63+
int numThreads = 50;
6464
final CountDownLatch readyLatch = new CountDownLatch(numThreads);
6565
final CountDownLatch finishLine = new CountDownLatch(numThreads);
6666

0 commit comments

Comments
 (0)