From 5ad00572b7dd50db5aa56e5075878a54cd75931c Mon Sep 17 00:00:00 2001
From: Kenneth Knowles <klk@google.com>
Date: Wed, 23 Oct 2024 13:03:04 -0400
Subject: [PATCH] Remove extraneous/incorrect ValidatesRunner classification
 from examples unit tests

---
 .../test/java/org/apache/beam/examples/WordCountTest.java   | 3 ---
 .../beam/examples/complete/TopWikipediaSessionsTest.java    | 3 ---
 .../apache/beam/examples/complete/game/GameStatsTest.java   | 3 ---
 .../beam/examples/complete/game/HourlyTeamScoreTest.java    | 3 ---
 .../apache/beam/examples/complete/game/UserScoreTest.java   | 5 -----
 .../beam/examples/cookbook/BigQueryTornadoesTest.java       | 6 ------
 .../apache/beam/examples/cookbook/DistinctExampleTest.java  | 4 ----
 .../apache/beam/examples/cookbook/FilterExamplesTest.java   | 4 ----
 .../org/apache/beam/examples/cookbook/JoinExamplesTest.java | 3 ---
 .../beam/examples/cookbook/MaxPerKeyExamplesTest.java       | 4 ----
 .../examples/cookbook/MinimalBigQueryTornadoesTest.java     | 6 ------
 .../apache/beam/examples/cookbook/TriggerExampleTest.java   | 3 ---
 .../beam/examples/kotlin/cookbook/DistinctExampleTest.kt    | 2 --
 .../beam/examples/kotlin/cookbook/FilterExamplesTest.kt     | 2 --
 .../beam/examples/kotlin/cookbook/JoinExamplesTest.kt       | 1 -
 .../beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt  | 2 --
 16 files changed, 54 deletions(-)

diff --git a/examples/java/src/test/java/org/apache/beam/examples/WordCountTest.java b/examples/java/src/test/java/org/apache/beam/examples/WordCountTest.java
index 6b9916e87271..43b06347a39a 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/WordCountTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/WordCountTest.java
@@ -25,7 +25,6 @@
 import org.apache.beam.sdk.coders.StringUtf8Coder;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.DoFn;
 import org.apache.beam.sdk.transforms.MapElements;
@@ -33,7 +32,6 @@
 import org.apache.beam.sdk.values.PCollection;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -66,7 +64,6 @@ public void testExtractWordsFn() throws Exception {
 
   /** Example test that tests a PTransform by using an in-memory input and inspecting the output. */
   @Test
-  @Category(ValidatesRunner.class)
   public void testCountWords() throws Exception {
     PCollection<String> input = p.apply(Create.of(WORDS).withCoder(StringUtf8Coder.of()));
 
diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsTest.java
index 96d10a1f72ed..614d289d2d60 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsTest.java
@@ -21,12 +21,10 @@
 import java.util.Arrays;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.values.PCollection;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -37,7 +35,6 @@ public class TopWikipediaSessionsTest {
   @Rule public TestPipeline p = TestPipeline.create();
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testComputeTopUsers() {
 
     PCollection<String> output =
diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java
index 33d3c5699477..9c99c3aafdcc 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java
@@ -24,13 +24,11 @@
 import org.apache.beam.sdk.options.PipelineOptionsFactory;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.values.KV;
 import org.apache.beam.sdk.values.PCollection;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -69,7 +67,6 @@ public class GameStatsTest implements Serializable {
 
   /** Test the calculation of 'spammy users'. */
   @Test
-  @Category(ValidatesRunner.class)
   public void testCalculateSpammyUsers() throws Exception {
     PCollection<KV<String, Integer>> input = p.apply(Create.of(USER_SCORES));
     PCollection<KV<String, Integer>> output = input.apply(new CalculateSpammyUsers());
diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java
index 1d89351adcf8..46d7b41746ab 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java
@@ -26,7 +26,6 @@
 import org.apache.beam.sdk.options.PipelineOptionsFactory;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.Filter;
 import org.apache.beam.sdk.transforms.MapElements;
@@ -37,7 +36,6 @@
 import org.joda.time.Instant;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -90,7 +88,6 @@ public class HourlyTeamScoreTest implements Serializable {
 
   /** Test the filtering. */
   @Test
-  @Category(ValidatesRunner.class)
   public void testUserScoresFilter() throws Exception {
 
     final Instant startMinTimestamp = new Instant(1447965680000L);
diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/game/UserScoreTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/game/UserScoreTest.java
index 04aa122054bd..22fe98a50304 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/complete/game/UserScoreTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/complete/game/UserScoreTest.java
@@ -26,7 +26,6 @@
 import org.apache.beam.sdk.coders.StringUtf8Coder;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.MapElements;
 import org.apache.beam.sdk.transforms.ParDo;
@@ -36,7 +35,6 @@
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -114,7 +112,6 @@ public void testParseEventFn() throws Exception {
 
   /** Tests ExtractAndSumScore("user"). */
   @Test
-  @Category(ValidatesRunner.class)
   public void testUserScoreSums() throws Exception {
 
     PCollection<String> input = p.apply(Create.of(GAME_EVENTS));
@@ -133,7 +130,6 @@ public void testUserScoreSums() throws Exception {
 
   /** Tests ExtractAndSumScore("team"). */
   @Test
-  @Category(ValidatesRunner.class)
   public void testTeamScoreSums() throws Exception {
 
     PCollection<String> input = p.apply(Create.of(GAME_EVENTS));
@@ -152,7 +148,6 @@ public void testTeamScoreSums() throws Exception {
 
   /** Test that bad input data is dropped appropriately. */
   @Test
-  @Category(ValidatesRunner.class)
   public void testUserScoresBadInput() throws Exception {
 
     PCollection<String> input = p.apply(Create.of(GAME_EVENTS2).withCoder(StringUtf8Coder.of()));
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesTest.java
index 2bd37a3caa52..110349c353e8 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesTest.java
@@ -22,7 +22,6 @@
 import org.apache.beam.examples.cookbook.BigQueryTornadoes.FormatCountsFn;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.ParDo;
 import org.apache.beam.sdk.values.KV;
@@ -31,7 +30,6 @@
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableList;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -41,7 +39,6 @@ public class BigQueryTornadoesTest {
   @Rule public TestPipeline p = TestPipeline.create();
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testExtractTornadoes() {
     TableRow row = new TableRow().set("month", "6").set("tornado", true);
     PCollection<TableRow> input = p.apply(Create.of(ImmutableList.of(row)));
@@ -51,7 +48,6 @@ public void testExtractTornadoes() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testNoTornadoes() {
     TableRow row = new TableRow().set("month", 6).set("tornado", false);
     PCollection<TableRow> inputs = p.apply(Create.of(ImmutableList.of(row)));
@@ -61,7 +57,6 @@ public void testNoTornadoes() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testEmpty() {
     PCollection<KV<Integer, Long>> inputs =
         p.apply(Create.empty(new TypeDescriptor<KV<Integer, Long>>() {}));
@@ -71,7 +66,6 @@ public void testEmpty() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testFormatCounts() {
     PCollection<KV<Integer, Long>> inputs =
         p.apply(Create.of(KV.of(3, 0L), KV.of(4, Long.MAX_VALUE), KV.of(5, Long.MIN_VALUE)));
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java
index 988a492ad4a9..7ec889f0d2b4 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java
@@ -22,13 +22,11 @@
 import org.apache.beam.sdk.coders.StringUtf8Coder;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.Distinct;
 import org.apache.beam.sdk.values.PCollection;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -39,7 +37,6 @@ public class DistinctExampleTest {
   @Rule public TestPipeline p = TestPipeline.create();
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testDistinct() {
     List<String> strings = Arrays.asList("k1", "k5", "k5", "k2", "k1", "k2", "k3");
 
@@ -52,7 +49,6 @@ public void testDistinct() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testDistinctEmpty() {
     List<String> strings = Arrays.asList();
 
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java
index dedc0e313350..4eeb5c4b7dd0 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java
@@ -22,13 +22,11 @@
 import org.apache.beam.examples.cookbook.FilterExamples.ProjectionFn;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.ParDo;
 import org.apache.beam.sdk.values.PCollection;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -68,7 +66,6 @@ public class FilterExamplesTest {
   @Rule public TestPipeline p = TestPipeline.create();
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testProjectionFn() {
     PCollection<TableRow> input = p.apply(Create.of(row1, row2, row3));
 
@@ -79,7 +76,6 @@ public void testProjectionFn() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testFilterSingleMonthDataFn() {
     PCollection<TableRow> input = p.apply(Create.of(outRow1, outRow2, outRow3));
 
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java
index b91ca985ddcd..d27572667752 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java
@@ -24,14 +24,12 @@
 import org.apache.beam.examples.cookbook.JoinExamples.ExtractEventDataFn;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.ParDo;
 import org.apache.beam.sdk.values.KV;
 import org.apache.beam.sdk.values.PCollection;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -107,7 +105,6 @@ public void testExtractCountryInfoFn() throws Exception {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testJoin() throws java.lang.Exception {
     PCollection<TableRow> input1 = p.apply("CreateEvent", Create.of(EVENT_ARRAY));
     PCollection<TableRow> input2 = p.apply("CreateCC", Create.of(CC_ARRAY));
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java
index 5c32f36660d6..410b151ed32f 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java
@@ -23,7 +23,6 @@
 import org.apache.beam.examples.cookbook.MaxPerKeyExamples.FormatMaxesFn;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.ParDo;
 import org.apache.beam.sdk.values.KV;
@@ -31,7 +30,6 @@
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableList;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -78,7 +76,6 @@ public class MaxPerKeyExamplesTest {
   @Rule public TestPipeline p = TestPipeline.create();
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testExtractTempFn() {
     PCollection<KV<Integer, Double>> results =
         p.apply(Create.of(TEST_ROWS)).apply(ParDo.of(new ExtractTempFn()));
@@ -87,7 +84,6 @@ public void testExtractTempFn() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testFormatMaxesFn() {
     PCollection<TableRow> results =
         p.apply(Create.of(TEST_KVS)).apply(ParDo.of(new FormatMaxesFn()));
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/MinimalBigQueryTornadoesTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/MinimalBigQueryTornadoesTest.java
index 7e922bc87965..fb08730a9f54 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/MinimalBigQueryTornadoesTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/MinimalBigQueryTornadoesTest.java
@@ -22,7 +22,6 @@
 import org.apache.beam.examples.cookbook.MinimalBigQueryTornadoes.FormatCountsFn;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.ParDo;
 import org.apache.beam.sdk.values.KV;
@@ -31,7 +30,6 @@
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableList;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -41,7 +39,6 @@ public class MinimalBigQueryTornadoesTest {
   @Rule public TestPipeline p = TestPipeline.create();
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testExtractTornadoes() {
     TableRow row = new TableRow().set("month", "6").set("tornado", true);
     PCollection<TableRow> input = p.apply(Create.of(ImmutableList.of(row)));
@@ -51,7 +48,6 @@ public void testExtractTornadoes() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testNoTornadoes() {
     TableRow row = new TableRow().set("month", 6).set("tornado", false);
     PCollection<TableRow> inputs = p.apply(Create.of(ImmutableList.of(row)));
@@ -61,7 +57,6 @@ public void testNoTornadoes() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testEmpty() {
     PCollection<KV<Integer, Long>> inputs =
         p.apply(Create.empty(new TypeDescriptor<KV<Integer, Long>>() {}));
@@ -71,7 +66,6 @@ public void testEmpty() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testFormatCounts() {
     PCollection<KV<Integer, Long>> inputs =
         p.apply(Create.of(KV.of(3, 0L), KV.of(4, Long.MAX_VALUE), KV.of(5, Long.MIN_VALUE)));
diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java
index 8f076a9d8d89..19c83c6eb73c 100644
--- a/examples/java/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java
+++ b/examples/java/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java
@@ -27,7 +27,6 @@
 import org.apache.beam.sdk.coders.StringUtf8Coder;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
-import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.transforms.Create;
 import org.apache.beam.sdk.transforms.DoFn;
 import org.apache.beam.sdk.transforms.ParDo;
@@ -42,7 +41,6 @@
 import org.joda.time.Instant;
 import org.junit.Rule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
@@ -118,7 +116,6 @@ public void testExtractTotalFlow() {
   }
 
   @Test
-  @Category(ValidatesRunner.class)
   public void testTotalFlow() {
     PCollection<KV<String, Integer>> flow =
         pipeline
diff --git a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/DistinctExampleTest.kt b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/DistinctExampleTest.kt
index 56702a3a1746..514727878a44 100644
--- a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/DistinctExampleTest.kt
+++ b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/DistinctExampleTest.kt
@@ -39,7 +39,6 @@ class DistinctExampleTest {
     fun pipeline(): TestPipeline = pipeline
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testDistinct() {
         val strings = listOf("k1", "k5", "k5", "k2", "k1", "k2", "k3")
         val input = pipeline.apply(Create.of(strings).withCoder(StringUtf8Coder.of()))
@@ -49,7 +48,6 @@ class DistinctExampleTest {
     }
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testDistinctEmpty() {
         val strings = listOf<String>()
         val input = pipeline.apply(Create.of(strings).withCoder(StringUtf8Coder.of()))
diff --git a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/FilterExamplesTest.kt b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/FilterExamplesTest.kt
index d5cb544a7606..8cfffe15fc65 100644
--- a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/FilterExamplesTest.kt
+++ b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/FilterExamplesTest.kt
@@ -64,7 +64,6 @@ class FilterExamplesTest {
     fun pipeline(): TestPipeline = pipeline
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testProjectionFn() {
         val input = pipeline.apply(Create.of(row1, row2, row3))
         val results = input.apply(ParDo.of(ProjectionFn()))
@@ -73,7 +72,6 @@ class FilterExamplesTest {
     }
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testFilterSingleMonthDataFn() {
         val input = pipeline.apply(Create.of(outRow1, outRow2, outRow3))
         val results = input.apply(ParDo.of(FilterSingleMonthDataFn(7)))
diff --git a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/JoinExamplesTest.kt b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/JoinExamplesTest.kt
index 8728a827229b..6bb818f5efa9 100644
--- a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/JoinExamplesTest.kt
+++ b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/JoinExamplesTest.kt
@@ -93,7 +93,6 @@ class JoinExamplesTest {
     }
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testJoin() {
         val input1 = pipeline.apply("CreateEvent", Create.of(EVENT_ARRAY))
         val input2 = pipeline.apply("CreateCC", Create.of(CC_ARRAY))
diff --git a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt
index 7995d9c1c795..409434e02686 100644
--- a/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt
+++ b/examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt
@@ -69,7 +69,6 @@ class MaxPerKeyExamplesTest {
     fun pipeline(): TestPipeline = pipeline
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testExtractTempFn() {
         val results = pipeline.apply(Create.of(testRows)).apply(ParDo.of<TableRow, KV<Int, Double>>(MaxPerKeyExamples.ExtractTempFn()))
         PAssert.that(results).containsInAnyOrder(ImmutableList.of(kv1, kv2, kv3))
@@ -77,7 +76,6 @@ class MaxPerKeyExamplesTest {
     }
 
     @Test
-    @Category(ValidatesRunner::class)
     fun testFormatMaxesFn() {
         val results = pipeline.apply(Create.of(testKvs)).apply(ParDo.of<KV<Int, Double>, TableRow>(MaxPerKeyExamples.FormatMaxesFn()))
         PAssert.that(results).containsInAnyOrder(resultRow1, resultRow2, resultRow3)