You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2013/05/02 03:27:46 UTC
git commit: CRUNCH-201: Handle checked exception in TrevniKeyTarget.
Contributed by Micah Whitacre.
Updated Branches:
refs/heads/master 5578d5e8b -> a8828d190
CRUNCH-201: Handle checked exception in TrevniKeyTarget. Contributed by Micah Whitacre.
Project: http://git-wip-us.apache.org/repos/asf/crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/a8828d19
Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/a8828d19
Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/a8828d19
Branch: refs/heads/master
Commit: a8828d19089512cf16fec1a4279f2b9db3638fe8
Parents: 5578d5e
Author: Josh Wills <jw...@apache.org>
Authored: Wed May 1 18:27:05 2013 -0700
Committer: Josh Wills <jw...@apache.org>
Committed: Wed May 1 18:27:05 2013 -0700
----------------------------------------------------------------------
.../crunch/io/avro/trevni/TrevniKeyTarget.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/crunch/blob/a8828d19/crunch-core/src/main/java/org/apache/crunch/io/avro/trevni/TrevniKeyTarget.java
----------------------------------------------------------------------
diff --git a/crunch-core/src/main/java/org/apache/crunch/io/avro/trevni/TrevniKeyTarget.java b/crunch-core/src/main/java/org/apache/crunch/io/avro/trevni/TrevniKeyTarget.java
index 555aaf4..44d259b 100644
--- a/crunch-core/src/main/java/org/apache/crunch/io/avro/trevni/TrevniKeyTarget.java
+++ b/crunch-core/src/main/java/org/apache/crunch/io/avro/trevni/TrevniKeyTarget.java
@@ -112,7 +112,11 @@ public class TrevniKeyTarget extends FileTargetImpl {
//Set value which will be ignored but should get past the FileOutputFormat.checkOutputSpecs(..)
//which requires the "mapred.output.dir" value to be set.
- FileOutputFormat.setOutputPath(job, outputPath);
+ try{
+ FileOutputFormat.setOutputPath(job, outputPath);
+ } catch(Exception ioe){
+ throw new RuntimeException(ioe);
+ }
CrunchOutputs.addNamedOutput(job, name,
bundle,