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 b5026b05a503..f7123b090bdb 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 @@ -3355,7 +3355,7 @@ public void onTimer(OnTimerContext c, PipelineOptions options) { } @Test - @Category(ValidatesRunner.class) + @Category({ValidatesRunner.class, UsesTestStream.class}) public void duplicateTimerSetting() { TestStream> stream = TestStream .create(KvCoder.of(StringUtf8Coder.of(), StringUtf8Coder.of()))