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);