You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2020/06/30 21:21:11 UTC
[beam] 08/09: Exclude Spotbugs validation because Spark Runner does
not support KeyInParDo
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 <ie...@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);