| commit | 456903cc308b3b11204517bdaa2b4e70962245a6 | [log] [tgz] |
|---|---|---|
| author | Kenneth Knowles <klk@google.com> | Tue May 11 09:20:40 2021 -0700 |
| committer | Kenneth Knowles <klk@google.com> | Tue May 11 09:20:40 2021 -0700 |
| tree | 4737260c871c71afccfd71fa3fc959b6f6f54a4c | |
| parent | d2fda334cd4d52ade90284a56295380cc335215d [diff] |
Set 5 second timeout for BeamFnLoggingServiceTest.testMultipleClientsFailingIsHandledGrafullyByServer
diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingServiceTest.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingServiceTest.java index 001a2a0..06e09fc 100644 --- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingServiceTest.java +++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingServiceTest.java
@@ -115,7 +115,7 @@ } } - @Test + @Test(timeout = 5000) public void testMultipleClientsFailingIsHandledGracefullyByServer() throws Exception { Collection<Callable<Void>> tasks = new ArrayList<>(); ConcurrentLinkedQueue<BeamFnApi.LogEntry> logs = new ConcurrentLinkedQueue<>();