This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch BEAM-7092-spark3
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 4ca870ed21377fca5d0b98cc693891600f14d002
Author: Ismaël Mejía <ieme...@gmail.com>
AuthorDate: Wed May 13 23:15:19 2020 +0200

    Exclude Spotbugs validation because Spark Runner does not support KeyInParDo
---
 .../apache/beam/runners/spark/translation/SparkProcessContext.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java
 
b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java
index 657da55..5e6b8b9 100644
--- 
a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java
+++ 
b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java
@@ -19,6 +19,7 @@ package org.apache.beam.runners.spark.translation;
 
 import static 
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument;
 
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import java.util.ArrayList;
 import java.util.Iterator;
 import org.apache.beam.runners.core.DoFnRunner;
@@ -157,6 +158,9 @@ class SparkProcessContext<FnInputT, FnOutputT, OutputT> {
       }
     }
 
+    @SuppressFBWarnings(
+        value = "NP_NONNULL_PARAM_VIOLATION",
+        justification = "UsesKeyInParDo not supported on Spark runner.")
     private void fireTimer(TimerInternals.TimerData timer) {
       StateNamespace namespace = timer.getNamespace();
       checkArgument(namespace instanceof StateNamespaces.WindowNamespace);

Reply via email to