Repository: nifi Updated Branches: refs/heads/master d5387679d -> 78fed3ed5
NIFI-3068 Adding @RequiresInstanceClassLoading to PutHDFS to ensure the security configuration of the Hadoop client is fully isolated between instances of PutHDFS Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/78fed3ed Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/78fed3ed Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/78fed3ed Branch: refs/heads/master Commit: 78fed3ed561b145e5c4043e1a4398485d7f639f7 Parents: d538767 Author: Bryan Bende <[email protected]> Authored: Tue Nov 22 14:58:25 2016 -0500 Committer: Bryan Bende <[email protected]> Committed: Tue Nov 22 16:41:44 2016 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/78fed3ed/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java index 5fbe577..414fd5e 100644 --- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java +++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/PutHDFS.java @@ -27,6 +27,7 @@ import org.apache.nifi.annotation.behavior.InputRequirement; import org.apache.nifi.annotation.behavior.InputRequirement.Requirement; import org.apache.nifi.annotation.behavior.ReadsAttribute; import org.apache.nifi.annotation.behavior.Restricted; +import org.apache.nifi.annotation.behavior.RequiresInstanceClassLoading; import org.apache.nifi.annotation.behavior.WritesAttribute; import org.apache.nifi.annotation.behavior.WritesAttributes; import org.apache.nifi.annotation.documentation.CapabilityDescription; @@ -67,6 +68,7 @@ import java.util.concurrent.TimeUnit; /** * This processor copies FlowFiles to HDFS. */ +@RequiresInstanceClassLoading @InputRequirement(Requirement.INPUT_REQUIRED) @Tags({"hadoop", "HDFS", "put", "copy", "filesystem", "restricted"}) @CapabilityDescription("Write FlowFile data to Hadoop Distributed File System (HDFS)")
