Repository: nifi Updated Branches: refs/heads/0.x ba6f51efc -> 104224343
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/10422434 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/10422434 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/10422434 Branch: refs/heads/0.x Commit: 104224343db5c39b240010b49c5e5b15ff4fe0f7 Parents: ba6f51e Author: Joe Gresock <[email protected]> Authored: Mon Jun 27 14:19:09 2016 +0000 Committer: Bryan Bende <[email protected]> Committed: Mon Jun 27 13:27:36 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/10422434/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 35421b4..c9c8191 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);
