This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 4a244b4d507 Add timeout to unit tests causing SickBay PostCommit
timeout (#25664)
4a244b4d507 is described below
commit 4a244b4d5072a025c931bc01a5fd2d60dc829734
Author: Yi Hu <[email protected]>
AuthorDate: Thu Mar 2 09:31:49 2023 -0500
Add timeout to unit tests causing SickBay PostCommit timeout (#25664)
---
.test-infra/jenkins/README.md | 1 +
sdks/java/core/src/test/java/org/apache/beam/sdk/PipelineTest.java | 2 ++
.../java/org/apache/beam/sdk/coders/PCollectionCustomCoderTest.java | 2 ++
sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroIOTest.java | 3 +++
sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileIOTest.java | 3 +++
.../test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java | 2 ++
.../src/test/java/org/apache/beam/sdk/transforms/MapElementsTest.java | 3 +++
.../core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java | 3 +++
.../test/java/org/apache/beam/sdk/transforms/SplittableDoFnTest.java | 3 +++
.../core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java | 3 +++
.../test/java/org/apache/beam/sdk/transforms/WithTimestampsTest.java | 3 +++
.../test/java/org/apache/beam/sdk/extensions/avro/io/AvroIOTest.java | 3 +++
12 files changed, 31 insertions(+)
diff --git a/.test-infra/jenkins/README.md b/.test-infra/jenkins/README.md
index 9b01da4b5a9..4d771959e48 100644
--- a/.test-infra/jenkins/README.md
+++ b/.test-infra/jenkins/README.md
@@ -145,6 +145,7 @@ Beam Jenkins overview page:
[link](https://ci-beam.apache.org/)
| beam_PostCommit_Javadoc |
[cron](https://ci-beam.apache.org/job/beam_PostCommit_Javadoc/),
[phrase](https://ci-beam.apache.org/job/beam_PostCommit_Javadoc_PR/) | `Run
Javadoc PostCommit` | [](https://ci-beam.apache.org/job/beam_PostCommit_Javadoc)
|
| beam_PostCommit_PortableJar_Flink |
[cron](https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/),
[phrase](https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink_PR/)
| `Run PortableJar_Flink PostCommit` | [](https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink)
|
| beam_PostCommit_PortableJar_Spark |
[cron](https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_PortableJar_Spark/),
[phrase](https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_PortableJar_Spark_PR/)
| `Run PortableJar_Spark PostCommit` | [](https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_PortableJar_Spark/)
|
+| beam_PostCommit_Java_Sickbay |
[cron](https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_Sickbay/),
[phrase](https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_Sickbay_PR/)
| `Run Java Sickbay` | [](https://ci-beam.apache.org/view/PostCommit/job/beam_PostCommit_Java_Sickbay/)
|
| beam_PostCommit_Py_VR_Dataflow |
[cron](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow/),
[phrase](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow_PR/) |
`Run Python Dataflow ValidatesRunner` | [](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow)
|
| beam_PostCommit_Py_VR_Dataflow_V2 |
[cron](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2/),
[phrase](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2_PR/)
| `Run Python Dataflow V2 ValidatesRunner` | [](https://ci-beam.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2)
|
| beam_PostCommit_Py_ValCont |
[cron](https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/),
[phrase](https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont_PR/) | `Run
Python Dataflow ValidatesContainer` | [](https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont)
|
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/PipelineTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/PipelineTest.java
index 5e19fa03315..711021f4938 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/PipelineTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/PipelineTest.java
@@ -75,6 +75,7 @@ import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -88,6 +89,7 @@ public class PipelineTest {
@Rule public final TestPipeline pipeline = TestPipeline.create();
@Rule public ExpectedLogs logged = ExpectedLogs.none(Pipeline.class);
@Rule public ExpectedException thrown = ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
// Mock class that throws a user code exception during the call to
// Pipeline.run().
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/PCollectionCustomCoderTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/PCollectionCustomCoderTest.java
index 16f0225d2f9..3558d7af0cc 100644
---
a/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/PCollectionCustomCoderTest.java
+++
b/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/PCollectionCustomCoderTest.java
@@ -46,6 +46,7 @@ import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -67,6 +68,7 @@ public class PCollectionCustomCoderTest {
@Rule public final transient ExpectedException thrown =
ExpectedException.none();
@Rule public final transient TestPipeline pipeline = TestPipeline.create();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
/** Wrapper of StringUtf8Coder with customizable exception-throwing. */
public static class CustomTestCoder extends CustomCoder<String> {
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroIOTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroIOTest.java
index 31d1587e248..4c2812efe0d 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroIOTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroIOTest.java
@@ -112,6 +112,7 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
import org.junit.rules.TemporaryFolder;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
import org.junit.runners.Parameterized;
@@ -186,6 +187,8 @@ public class AvroIOTest implements Serializable {
@Rule public transient ExpectedException expectedException =
ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
@Parameterized.Parameters(name = "{index}: {0}")
public static Collection<Object[]> params() {
return Arrays.asList(new Object[][] {{true}, {false}});
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileIOTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileIOTest.java
index a4629ad7900..da794f5a49b 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileIOTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileIOTest.java
@@ -76,6 +76,7 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
import org.junit.rules.TemporaryFolder;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -88,6 +89,8 @@ public class FileIOTest implements Serializable {
@Rule public transient ExpectedException thrown = ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
@Test
@Category(NeedsRunner.class)
public void testMatchAndMatchAll() throws IOException {
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java
index 68a6cbccf77..22a50d47037 100644
---
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java
+++
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupIntoBatchesTest.java
@@ -64,6 +64,7 @@ import org.joda.time.Instant;
import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
import org.slf4j.Logger;
@@ -80,6 +81,7 @@ public class GroupIntoBatchesTest implements Serializable {
private static final int ALLOWED_LATENESS = 0;
private static final Logger LOG =
LoggerFactory.getLogger(GroupIntoBatchesTest.class);
@Rule public transient TestPipeline pipeline = TestPipeline.create();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
private transient ArrayList<KV<String, String>> data =
createTestData(EVEN_NUM_ELEMENTS);
private static ArrayList<KV<String, String>> createTestData(long
numElements) {
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MapElementsTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MapElementsTest.java
index 390a6135807..dbbcb0e20d2 100644
---
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MapElementsTest.java
+++
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MapElementsTest.java
@@ -50,6 +50,7 @@ import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -61,6 +62,8 @@ public class MapElementsTest implements Serializable {
@Rule public transient ExpectedException thrown = ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
/**
* A {@link SimpleFunction} to test that the coder registry can propagate
coders that are bound to
* type variables.
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
index d4573b49081..909703aa353 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
@@ -172,6 +172,7 @@ import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -191,6 +192,8 @@ public class ParDoTest implements Serializable {
@Rule public final transient TestPipeline pipeline = TestPipeline.create();
@Rule public transient ExpectedException thrown = ExpectedException.none();
+
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
}
private static class PrintingDoFn extends DoFn<String, String> {
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/SplittableDoFnTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/SplittableDoFnTest.java
index 5d7f7720bb4..0012f0d4a19 100644
---
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/SplittableDoFnTest.java
+++
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/SplittableDoFnTest.java
@@ -83,6 +83,7 @@ import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -95,6 +96,8 @@ import org.junit.runners.JUnit4;
})
public class SplittableDoFnTest implements Serializable {
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
static class PairStringWithIndexToLengthBase extends DoFn<String, KV<String,
Integer>> {
@ProcessElement
public ProcessContinuation process(
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java
index 2dcce79ccf2..561e384f000 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java
@@ -72,6 +72,7 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.internal.matchers.ThrowableMessageMatcher;
import org.junit.rules.ExpectedException;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -89,6 +90,8 @@ public class ViewTest implements Serializable {
@Rule public transient ExpectedException thrown = ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
@Test
@Category(ValidatesRunner.class)
public void testSingletonSideInput() {
diff --git
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsTest.java
index 50b3831d893..5b8eb6c256e 100644
---
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsTest.java
+++
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsTest.java
@@ -33,6 +33,7 @@ import org.junit.Rule;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
@@ -44,6 +45,8 @@ public class WithTimestampsTest implements Serializable {
@Rule public transient ExpectedException thrown = ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
@Test
@Category(ValidatesRunner.class)
public void withTimestampsShouldApplyTimestamps() {
diff --git
a/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/io/AvroIOTest.java
b/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/io/AvroIOTest.java
index ac2200b6dc4..7456435948d 100644
---
a/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/io/AvroIOTest.java
+++
b/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/io/AvroIOTest.java
@@ -118,6 +118,7 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
import org.junit.rules.TemporaryFolder;
+import org.junit.rules.Timeout;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;
import org.junit.runners.Parameterized;
@@ -192,6 +193,8 @@ public class AvroIOTest implements Serializable {
@Rule public transient ExpectedException expectedException =
ExpectedException.none();
+ @Rule public transient Timeout globalTimeout = Timeout.seconds(1200);
+
@Parameterized.Parameters(name = "{index}: {0}")
public static Collection<Object[]> params() {
return Arrays.asList(new Object[][] {{true}, {false}});
