Repository: nifi Updated Branches: refs/heads/master 08d0f3e59 -> 3ecccf02d
NIFI-1267: Extend processor and force an Exception to be thrown from changeOwner instead of relying on permissions to cause failure, since root user has super permissions and as a result flowfiles are not routed to failure Signed-off-by: joewitt <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/fee9f381 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/fee9f381 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/fee9f381 Branch: refs/heads/master Commit: fee9f381a7a90afc703c4e72e5aa6532831447c5 Parents: 46623c2 Author: Mark Payne <[email protected]> Authored: Mon Dec 7 17:06:54 2015 -0500 Committer: joewitt <[email protected]> Committed: Mon Dec 7 17:09:17 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/hadoop/PutHDFSTest.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/fee9f381/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/PutHDFSTest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/PutHDFSTest.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/PutHDFSTest.java index fe3b5b8..97ab990 100644 --- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/PutHDFSTest.java +++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/PutHDFSTest.java @@ -40,6 +40,7 @@ import org.apache.nifi.components.ValidationResult; import org.apache.nifi.flowfile.attributes.CoreAttributes; import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.Relationship; +import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.util.MockFlowFile; import org.apache.nifi.util.MockProcessContext; import org.apache.nifi.util.TestRunner; @@ -213,7 +214,12 @@ public class PutHDFSTest { // forcing IOException downstream fs.setPermission(p, new FsPermission(FsAction.READ, FsAction.READ, FsAction.READ)); - TestRunner runner = TestRunners.newTestRunner(PutHDFS.class); + TestRunner runner = TestRunners.newTestRunner(new PutHDFS() { + @Override + protected void changeOwner(ProcessContext context, FileSystem hdfs, Path name) { + throw new ProcessException("Forcing Exception to get thrown in order to verify proper handling"); + } + }); runner.setProperty(PutHDFS.DIRECTORY, dirName); runner.setProperty(PutHDFS.CONFLICT_RESOLUTION, "replace"); runner.setValidateExpressionUsage(false);
