Repository: nifi Updated Branches: refs/heads/master ff341271a -> e3d13ecf5
NIFI-920: Adding InvalidPathException handling to UnpackContent Signed-off-by: Bryan Bende <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/e3d13ecf Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/e3d13ecf Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/e3d13ecf Branch: refs/heads/master Commit: e3d13ecf50f5096328d7576d1e97de939ddd3009 Parents: ff34127 Author: Joe Gresock <[email protected]> Authored: Mon Jun 27 14:19:09 2016 +0000 Committer: Bryan Bende <[email protected]> Committed: Mon Jun 27 13:49:49 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/UnpackContent.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/e3d13ecf/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UnpackContent.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UnpackContent.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UnpackContent.java index 933b027..6f9e7a2 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UnpackContent.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UnpackContent.java @@ -20,6 +20,7 @@ import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; +import java.nio.file.InvalidPathException; import java.nio.file.Path; import java.util.ArrayList; import java.util.Collections; @@ -271,7 +272,7 @@ public class UnpackContent extends AbstractProcessor { session.transfer(flowFile, REL_ORIGINAL); session.getProvenanceReporter().fork(flowFile, unpacked); logger.info("Unpacked {} into {} and transferred to success", new Object[]{flowFile, unpacked}); - } catch (final ProcessException e) { + } catch (final ProcessException | InvalidPathException e) { logger.error("Unable to unpack {} due to {}; routing to failure", new Object[]{flowFile, e}); session.transfer(flowFile, REL_FAILURE); session.remove(unpacked);
