crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject git commit: CRUNCH-201: Handle checked exception in TrevniKeyTarget. Contributed by Micah Whitacre.
Date Thu, 02 May 2013 01:27:46 GMT
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 <jwills@apache.org>
Authored: Wed May 1 18:27:05 2013 -0700
Committer: Josh Wills <jwills@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,


Mime
View raw message