apache · TheNeuralBit · Mar 3, 2021 · Feb 26, 2021 · Feb 26, 2021 · Feb 26, 2021
diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -94,12 +94,6 @@ class BeamModulePlugin implements Plugin<Project> {
     /** Classes triggering Checker failures. A map from class name to the bug filed against checkerframework. */
     Map<String, String> classesTriggerCheckerBugs = [:]
 
-    /**
-     Some module's tests take a very long time to compile with checkerframework.
-     Until that is solved, set this flag to skip checking for those tests.
-     */
-    boolean checkerTooSlowOnTests = false
-
     /** Controls whether the dependency analysis plugin is enabled. */
     boolean enableStrictDependencies = false
 
@@ -833,7 +827,12 @@ class BeamModulePlugin implements Plugin<Project> {
           'org.checkerframework.checker.nullness.NullnessChecker'
         ]
 
-        excludeTests = configuration.checkerTooSlowOnTests
+        // Always exclude checkerframework on tests. It's slow, and it often
+        // raises erroneous error because we don't have checker annotations for
+        // test libraries like junit and hamcrest. See BEAM-11436.
+        // Consider re-enabling if we can get annotations for the test libraries
+        // we use.
+        excludeTests = true
 
         extraJavacArgs = [
           "-AskipDefs=${skipDefCombinedRegex}",

diff --git a/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java b/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java
@@ -62,9 +62,6 @@
 
 /** End-to-end integration test of {@link WindowedWordCount}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class WindowedWordCountIT {
 
   @Rule public TestName testName = new TestName();

diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java b/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java
@@ -42,9 +42,6 @@
 
 /** End-to-end tests of TrafficMaxLaneFlowIT. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class TrafficMaxLaneFlowIT {
   private static final Logger LOG = LoggerFactory.getLogger(TrafficMaxLaneFlowIT.class);
   private TrafficMaxLaneFlowOptions options;

diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java b/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java
@@ -42,9 +42,6 @@
 
 /** End-to-end tests of TrafficRoutes. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class TrafficRoutesIT {
   private static final Logger LOG = LoggerFactory.getLogger(TrafficRoutesIT.class);
   private TrafficRoutesOptions options;

diff --git a/...on-java/src/test/java/org/apache/beam/runners/core/construction/CoderTranslationTest.java b/...on-java/src/test/java/org/apache/beam/runners/core/construction/CoderTranslationTest.java
@@ -68,7 +68,6 @@
 /** Tests for {@link CoderTranslation}. */
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class CoderTranslationTest {
   private static final Set<Coder<?>> KNOWN_CODERS =

diff --git a/...ruction-java/src/test/java/org/apache/beam/runners/core/construction/CommonCoderTest.java b/...ruction-java/src/test/java/org/apache/beam/runners/core/construction/CommonCoderTest.java
@@ -91,7 +91,6 @@
 @RunWith(Parameterized.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class CommonCoderTest {
   private static final String STANDARD_CODERS_YAML_PATH =

diff --git a/.../src/test/java/org/apache/beam/runners/core/construction/DefaultArtifactResolverTest.java b/.../src/test/java/org/apache/beam/runners/core/construction/DefaultArtifactResolverTest.java
@@ -30,9 +30,6 @@
 import org.junit.runners.JUnit4;
 
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class DefaultArtifactResolverTest {
   private RunnerApi.Pipeline createEmptyPipeline(
       Iterable<RunnerApi.ArtifactInformation> dependencies) {

diff --git a/...ava/src/test/java/org/apache/beam/runners/core/construction/ForwardingPTransformTest.java b/...ava/src/test/java/org/apache/beam/runners/core/construction/ForwardingPTransformTest.java
@@ -47,9 +47,6 @@
 
 /** Tests for {@link ForwardingPTransform}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class ForwardingPTransformTest {
   @Rule public ExpectedException thrown = ExpectedException.none();
 

diff --git a/...uction-java/src/test/java/org/apache/beam/runners/core/construction/MorePipelineTest.java b/...uction-java/src/test/java/org/apache/beam/runners/core/construction/MorePipelineTest.java
@@ -50,7 +50,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class MorePipelineTest {
 

diff --git a/...a/src/test/java/org/apache/beam/runners/core/construction/PCollectionTranslationTest.java b/...a/src/test/java/org/apache/beam/runners/core/construction/PCollectionTranslationTest.java
@@ -63,9 +63,6 @@
 
 /** Tests for {@link PCollectionTranslation}. */
 @RunWith(Parameterized.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class PCollectionTranslationTest {
   // Each spec activates tests of all subsets of its fields
   @Parameters(name = "{index}: {0}")

diff --git a/...-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java b/...-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java
@@ -85,7 +85,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class PTransformMatchersTest implements Serializable {
   @Rule

diff --git a/...a/src/test/java/org/apache/beam/runners/core/construction/PTransformReplacementsTest.java b/...a/src/test/java/org/apache/beam/runners/core/construction/PTransformReplacementsTest.java
@@ -41,9 +41,6 @@
 
 /** Tests for {@link PTransformReplacements}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class PTransformReplacementsTest {
   @Rule public TestPipeline pipeline = TestPipeline.create().enableAbandonedNodeEnforcement(false);
   @Rule public ExpectedException thrown = ExpectedException.none();

diff --git a/...va/src/test/java/org/apache/beam/runners/core/construction/PTransformTranslationTest.java b/...va/src/test/java/org/apache/beam/runners/core/construction/PTransformTranslationTest.java
@@ -62,9 +62,6 @@
 
 /** Tests for {@link PTransformTranslation}. */
 @RunWith(Parameterized.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class PTransformTranslationTest {
 
   @Parameters(name = "{index}: {0}")

diff --git a/...c/test/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslationTest.java b/...c/test/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslationTest.java
@@ -42,9 +42,6 @@
 import org.junit.runners.Parameterized.Parameters;
 
 /** Tests for {@link PipelineOptionsTranslation}. */
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class PipelineOptionsTranslationTest {
   /** Tests that translations can round-trip through the proto format. */
   @RunWith(Parameterized.class)

diff --git a/...java/src/test/java/org/apache/beam/runners/core/construction/PipelineTranslationTest.java b/...java/src/test/java/org/apache/beam/runners/core/construction/PipelineTranslationTest.java
@@ -72,7 +72,6 @@
 @RunWith(Parameterized.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class PipelineTranslationTest {
   @Parameter(0)

diff --git a/...-java/src/test/java/org/apache/beam/runners/core/construction/ReplacementOutputsTest.java b/...-java/src/test/java/org/apache/beam/runners/core/construction/ReplacementOutputsTest.java
@@ -45,9 +45,6 @@
 
 /** Tests for {@link ReplacementOutputs}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class ReplacementOutputsTest {
   @Rule public ExpectedException thrown = ExpectedException.none();
   private TestPipeline p = TestPipeline.create();

diff --git a/...n-java/src/test/java/org/apache/beam/runners/core/construction/SchemaTranslationTest.java b/...n-java/src/test/java/org/apache/beam/runners/core/construction/SchemaTranslationTest.java
@@ -42,9 +42,6 @@
 
 /** Tests for {@link SchemaTranslation}. */
 @RunWith(Enclosed.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class SchemaTranslationTest {
 
   /** Tests round-trip proto encodings for {@link Schema}. */

diff --git a/...ction-java/src/test/java/org/apache/beam/runners/core/construction/SdkComponentsTest.java b/...ction-java/src/test/java/org/apache/beam/runners/core/construction/SdkComponentsTest.java
@@ -50,9 +50,6 @@
 
 /** Tests for {@link SdkComponents}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class SdkComponentsTest {
   @Rule public TestPipeline pipeline = TestPipeline.create().enableAbandonedNodeEnforcement(false);
   @Rule public ExpectedException thrown = ExpectedException.none();

diff --git a/...-construction-java/src/test/java/org/apache/beam/runners/core/construction/TimerTest.java b/...-construction-java/src/test/java/org/apache/beam/runners/core/construction/TimerTest.java
@@ -34,9 +34,6 @@
 
 /** Tests for {@link Timer}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class TimerTest {
   private static final Instant FIRE_TIME = new Instant(123L);
   private static final Instant HOLD_TIME = new Instant(456L);

diff --git a/...-java/src/test/java/org/apache/beam/runners/core/construction/TriggerTranslationTest.java b/...-java/src/test/java/org/apache/beam/runners/core/construction/TriggerTranslationTest.java
@@ -43,9 +43,6 @@
 
 /** Tests for utilities in {@link TriggerTranslation}. */
 @RunWith(Parameterized.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class TriggerTranslationTest {
 
   @AutoValue

diff --git a/...st/java/org/apache/beam/runners/core/construction/UnboundedReadFromBoundedSourceTest.java b/...st/java/org/apache/beam/runners/core/construction/UnboundedReadFromBoundedSourceTest.java
@@ -72,9 +72,6 @@
 
 /** Unit tests for {@link UnboundedReadFromBoundedSource}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class UnboundedReadFromBoundedSourceTest {
 
   @Rule public TemporaryFolder tmpFolder = new TemporaryFolder();

diff --git a/...c/test/java/org/apache/beam/runners/core/construction/UnsupportedOverrideFactoryTest.java b/...c/test/java/org/apache/beam/runners/core/construction/UnsupportedOverrideFactoryTest.java
@@ -30,7 +30,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class UnsupportedOverrideFactoryTest {
   @Rule public ExpectedException thrown = ExpectedException.none();

diff --git a/...java/src/test/java/org/apache/beam/runners/core/construction/ValidateRunnerXlangTest.java b/...java/src/test/java/org/apache/beam/runners/core/construction/ValidateRunnerXlangTest.java
@@ -85,9 +85,6 @@
  * details.
  */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class ValidateRunnerXlangTest implements Serializable {
   @Rule public transient TestPipeline testPipeline = TestPipeline.create();
   private PipelineResult pipelineResult;

diff --git a/...test/java/org/apache/beam/runners/core/construction/WindowingStrategyTranslationTest.java b/...test/java/org/apache/beam/runners/core/construction/WindowingStrategyTranslationTest.java
@@ -64,7 +64,6 @@
 @RunWith(Enclosed.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class WindowingStrategyTranslationTest {
   // Each spec activates tests of all subsets of its fields

diff --git a/...rc/test/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuserTest.java b/...rc/test/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuserTest.java
@@ -60,9 +60,6 @@
 
 /** Tests for {@link GreedyPipelineFuser}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class GreedyPipelineFuserTest {
   // Contains the 'go' and 'py' environments, and a default 'impulse' step and output.
   private Components partialComponents;

diff --git a/...a/src/test/java/org/apache/beam/runners/core/construction/graph/GreedyStageFuserTest.java b/...a/src/test/java/org/apache/beam/runners/core/construction/graph/GreedyStageFuserTest.java
@@ -54,9 +54,6 @@
 
 /** Tests for {@link GreedyStageFuser}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class GreedyStageFuserTest {
   @Rule public ExpectedException thrown = ExpectedException.none();
 

diff --git a/...src/test/java/org/apache/beam/runners/core/construction/graph/OutputDeduplicatorTest.java b/...src/test/java/org/apache/beam/runners/core/construction/graph/OutputDeduplicatorTest.java
@@ -51,7 +51,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class OutputDeduplicatorTest {
   @Test

diff --git a/...ache/beam/runners/core/construction/resources/ClasspathScanningResourcesDetectorTest.java b/...ache/beam/runners/core/construction/resources/ClasspathScanningResourcesDetectorTest.java
@@ -40,9 +40,6 @@
 import org.junit.rules.TemporaryFolder;
 import org.mockito.Mockito;
 
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class ClasspathScanningResourcesDetectorTest {
 
   @Rule public transient TemporaryFolder tmpFolder = new TemporaryFolder();

diff --git a/.../test/java/org/apache/beam/runners/core/construction/resources/PipelineResourcesTest.java b/.../test/java/org/apache/beam/runners/core/construction/resources/PipelineResourcesTest.java
@@ -41,9 +41,6 @@
 
 /** Tests for PipelineResources. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class PipelineResourcesTest {
 
   @Rule public transient TemporaryFolder tmpFolder = new TemporaryFolder();

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/InMemoryTimerInternalsTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/InMemoryTimerInternalsTest.java
@@ -30,9 +30,6 @@
 
 /** Tests for {@link InMemoryTimerInternals}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class InMemoryTimerInternalsTest {
 
   private static final StateNamespace NS1 = new StateNamespaceForTest("NS1");

diff --git a/.../core-java/src/test/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunnerTest.java b/.../core-java/src/test/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunnerTest.java
@@ -44,9 +44,6 @@
 
 /** Unit tests for {@link LateDataDroppingDoFnRunner}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class LateDataDroppingDoFnRunnerTest {
   private static final FixedWindows WINDOW_FN = FixedWindows.of(Duration.millis(10));
 

diff --git a/...org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvokerTest.java b/...org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvokerTest.java
@@ -52,7 +52,6 @@
 /** Tests for {@link OutputAndTimeBoundedSplittableProcessElementInvoker}. */
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class OutputAndTimeBoundedSplittableProcessElementInvokerTest {
   @Rule public transient ExpectedException e = ExpectedException.none();

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/ReduceFnTester.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/ReduceFnTester.java
@@ -85,7 +85,6 @@
  */
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class ReduceFnTester<InputT, OutputT, W extends BoundedWindow> {
   private static final String KEY = "TEST_KEY";

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/SideInputHandlerTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/SideInputHandlerTest.java
@@ -44,9 +44,6 @@
 
 /** Unit tests for {@link SideInputHandler}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class SideInputHandlerTest {
 
   @Test

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java
@@ -63,7 +63,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class SimpleDoFnRunnerTest {
   @Rule public ExpectedException thrown = ExpectedException.none();

diff --git a/...ava/src/test/java/org/apache/beam/runners/core/SimplePushbackSideInputDoFnRunnerTest.java b/...ava/src/test/java/org/apache/beam/runners/core/SimplePushbackSideInputDoFnRunnerTest.java
@@ -79,7 +79,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class SimplePushbackSideInputDoFnRunnerTest {
   @Mock StepContext mockStepContext;

diff --git a/...rs/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoProcessFnTest.java b/...rs/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoProcessFnTest.java
@@ -77,9 +77,6 @@
 
 /** Tests for {@link SplittableParDoViaKeyedWorkItems.ProcessFn}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class SplittableParDoProcessFnTest {
   private static final int MAX_OUTPUTS_PER_BUNDLE = 10000;
   private static final Duration MAX_BUNDLE_DURATION = Duration.standardSeconds(5);

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/StateInternalsTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/StateInternalsTest.java
@@ -60,9 +60,6 @@
 import org.junit.Test;
 
 /** Tests for {@link StateInternals}. */
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public abstract class StateInternalsTest {
 
   private static final BoundedWindow WINDOW_1 = new IntervalWindow(new Instant(0), new Instant(10));

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/StatefulDoFnRunnerTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/StatefulDoFnRunnerTest.java
@@ -63,7 +63,6 @@
 @RunWith(JUnit4.class)
 @SuppressWarnings({
   "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 })
 public class StatefulDoFnRunnerTest {
 

diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java
@@ -31,9 +31,6 @@
 import org.joda.time.Instant;
 
 /** Matchers that are useful for working with Windowing, Timestamps, etc. */
-@SuppressWarnings({
-  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
-})
 public class WindowMatchers {
 
   public static <T> Matcher<WindowedValue<? extends T>> isWindowedValue(