This is an automated email from the ASF dual-hosted git repository. bbende pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push: new 2691ad0451 NIFI-12474: remove TriggerWhenEmpty for DeleteHDFS (#8125) 2691ad0451 is described below commit 2691ad04511c5369412488f668ab6f2a7b31997f Author: Emilio Setiadarma <51312775+emiliosetiada...@users.noreply.github.com> AuthorDate: Wed Dec 13 08:42:40 2023 -0800 NIFI-12474: remove TriggerWhenEmpty for DeleteHDFS (#8125) --- .../main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java index b56f561d14..0cab0b0bdc 100644 --- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java +++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java @@ -25,7 +25,6 @@ import org.apache.hadoop.security.UserGroupInformation; import org.apache.nifi.annotation.behavior.InputRequirement; import org.apache.nifi.annotation.behavior.Restricted; import org.apache.nifi.annotation.behavior.Restriction; -import org.apache.nifi.annotation.behavior.TriggerWhenEmpty; import org.apache.nifi.annotation.behavior.WritesAttribute; import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.documentation.CapabilityDescription; @@ -52,7 +51,6 @@ import java.util.Set; import java.util.regex.Matcher; import java.util.regex.Pattern; -@TriggerWhenEmpty @InputRequirement(InputRequirement.Requirement.INPUT_ALLOWED) @Tags({"hadoop", "HCFS", "HDFS", "delete", "remove", "filesystem"}) @CapabilityDescription("Deletes one or more files or directories from HDFS. The path can be provided as an attribute from an incoming FlowFile, " @@ -63,9 +61,9 @@ import java.util.regex.Pattern; + " flowfile then provided there are no detected failures it will be transferred to success otherwise it will be sent to false. If" + " knowledge of globbed files deleted is necessary use ListHDFS first to produce a specific list of files to delete. ") @Restricted(restrictions = { - @Restriction( - requiredPermission = RequiredPermission.WRITE_DISTRIBUTED_FILESYSTEM, - explanation = "Provides operator the ability to delete any file that NiFi has access to in HDFS or the local filesystem.") + @Restriction( + requiredPermission = RequiredPermission.WRITE_DISTRIBUTED_FILESYSTEM, + explanation = "Provides operator the ability to delete any file that NiFi has access to in HDFS or the local filesystem.") }) @WritesAttributes({ @WritesAttribute(attribute="hdfs.filename", description="HDFS file to be deleted. "