This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch support/nifi-1.x in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 463e965f588ec405e1e9d49d5246f81b069a70e2 Author: exceptionfactory <exceptionfact...@apache.org> AuthorDate: Wed Feb 14 15:03:11 2024 -0600 NIFI-12792 Deprecated nifi-spark-bundle components for removal This closes #8408 Signed-off-by: Joseph Witt <joew...@apache.org> --- .../java/org/apache/nifi/controller/livy/LivySessionController.java | 2 ++ .../java/org/apache/nifi/processors/livy/ExecuteSparkInteractive.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-controller-service/src/main/java/org/apache/nifi/controller/livy/LivySessionController.java b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-controller-service/src/main/java/org/apache/nifi/controller/livy/LivySessionController.java index f691346c17..904fe75183 100644 --- a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-controller-service/src/main/java/org/apache/nifi/controller/livy/LivySessionController.java +++ b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-controller-service/src/main/java/org/apache/nifi/controller/livy/LivySessionController.java @@ -36,6 +36,7 @@ import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.BasicCredentialsProvider; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.nifi.annotation.documentation.CapabilityDescription; +import org.apache.nifi.annotation.documentation.DeprecationNotice; import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.annotation.lifecycle.OnDisabled; import org.apache.nifi.annotation.lifecycle.OnEnabled; @@ -84,6 +85,7 @@ import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; +@DeprecationNotice(reason = "Unmaintained and planned for removal in version 2.0") @Tags({"Livy", "REST", "Spark", "http"}) @CapabilityDescription("Manages pool of Spark sessions over HTTP") public class LivySessionController extends AbstractControllerService implements LivySessionService { diff --git a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/main/java/org/apache/nifi/processors/livy/ExecuteSparkInteractive.java b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/main/java/org/apache/nifi/processors/livy/ExecuteSparkInteractive.java index 41eaac0152..99181eca3d 100644 --- a/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/main/java/org/apache/nifi/processors/livy/ExecuteSparkInteractive.java +++ b/nifi-nar-bundles/nifi-spark-bundle/nifi-livy-processors/src/main/java/org/apache/nifi/processors/livy/ExecuteSparkInteractive.java @@ -44,6 +44,7 @@ import org.apache.http.client.methods.HttpPost; import org.apache.http.entity.StringEntity; import org.apache.nifi.annotation.behavior.InputRequirement; import org.apache.nifi.annotation.documentation.CapabilityDescription; +import org.apache.nifi.annotation.documentation.DeprecationNotice; import org.apache.nifi.annotation.documentation.Tags; import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.controller.api.livy.exception.SessionManagerException; @@ -64,6 +65,7 @@ import org.codehaus.jettison.json.JSONObject; import org.apache.nifi.controller.api.livy.LivySessionService; import org.apache.nifi.expression.ExpressionLanguageScope; +@DeprecationNotice(reason = "Unmaintained and planned for removal in version 2.0") @InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED) @Tags({"spark", "livy", "http", "execute"}) @CapabilityDescription("Execute Spark Code over a Livy-managed HTTP session to a live Spark context. Supports cached RDD sharing.")