This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 5aa7ba9bf97bc23b97b79d057030bf3b4e5a45ec Author: exceptionfactory <[email protected]> AuthorDate: Tue Nov 22 14:16:49 2022 -0600 NIFI-10860 This closes #6704. Deprecated ExecuteFlumeSink and ExecuteFlumeSource Signed-off-by: Joe Witt <[email protected]> --- .../main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java | 2 ++ .../main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java index 7931ffeadc..8e7669ea83 100644 --- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java +++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java @@ -28,6 +28,7 @@ import org.apache.nifi.annotation.behavior.Restricted; import org.apache.nifi.annotation.behavior.Restriction; import org.apache.nifi.annotation.behavior.TriggerSerially; 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.OnScheduled; import org.apache.nifi.annotation.lifecycle.OnStopped; @@ -58,6 +59,7 @@ import java.util.Set; explanation = "Provides operator the ability to execute arbitrary Flume configurations assuming all permissions that NiFi has.") } ) +@DeprecationNotice(reason = "Apache Flume pipelines should be implemented using Apache NiFi components") public class ExecuteFlumeSink extends AbstractFlumeProcessor { public static final PropertyDescriptor SINK_TYPE = new PropertyDescriptor.Builder() diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java index d972e4e785..12c759278a 100644 --- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java +++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java @@ -32,6 +32,7 @@ import org.apache.nifi.annotation.behavior.Restricted; import org.apache.nifi.annotation.behavior.Restriction; import org.apache.nifi.annotation.behavior.TriggerSerially; 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.OnScheduled; import org.apache.nifi.annotation.lifecycle.OnStopped; @@ -64,6 +65,7 @@ import java.util.concurrent.atomic.AtomicReference; explanation = "Provides operator the ability to execute arbitrary Flume configurations assuming all permissions that NiFi has.") } ) +@DeprecationNotice(reason = "Apache Flume pipelines should be implemented using Apache NiFi components") public class ExecuteFlumeSource extends AbstractFlumeProcessor { public static final PropertyDescriptor SOURCE_TYPE = new PropertyDescriptor.Builder()
