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 2012/12/18 20:43:36 UTC
git commit: CRUNCH-134: Move CrunchRuntimeException to
org.apache.crunch
Updated Branches:
refs/heads/master ac317a185 -> 29de385be
CRUNCH-134: Move CrunchRuntimeException to org.apache.crunch
Project: http://git-wip-us.apache.org/repos/asf/incubator-crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-crunch/commit/29de385b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-crunch/tree/29de385b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-crunch/diff/29de385b
Branch: refs/heads/master
Commit: 29de385be69738de3acd3369216c4839620689c7
Parents: ac317a1
Author: Josh Wills <jw...@apache.org>
Authored: Tue Dec 18 09:22:28 2012 -0800
Committer: Josh Wills <jw...@apache.org>
Committed: Tue Dec 18 09:43:29 2012 -0800
----------------------------------------------------------------------
.../org/apache/crunch/io/hbase/HBaseTarget.java | 2 +-
.../org/apache/crunch/lib/join/MapsideJoinIT.java | 2 +-
.../org/apache/crunch/CrunchRuntimeException.java | 54 +++++++++++++++
.../java/org/apache/crunch/impl/mr/MRPipeline.java | 2 +-
.../crunch/impl/mr/emit/MultipleOutputEmitter.java | 2 +-
.../apache/crunch/impl/mr/emit/OutputEmitter.java | 2 +-
.../apache/crunch/impl/mr/run/CrunchMapper.java | 1 +
.../apache/crunch/impl/mr/run/CrunchReducer.java | 1 +
.../crunch/impl/mr/run/CrunchRuntimeException.java | 43 ------------
.../crunch/impl/mr/run/CrunchTaskContext.java | 1 +
.../java/org/apache/crunch/impl/mr/run/RTNode.java | 1 +
.../org/apache/crunch/lib/join/MapsideJoin.java | 2 +-
.../crunch/materialize/MaterializableIterable.java | 2 +-
.../main/java/org/apache/crunch/types/PTypes.java | 2 +-
.../main/java/org/apache/crunch/types/Protos.java | 2 +-
.../java/org/apache/crunch/types/TupleFactory.java | 2 +-
.../apache/crunch/types/avro/AvroDeepCopier.java | 2 +-
.../types/writable/GenericArrayWritable.java | 2 +-
.../crunch/types/writable/WritableDeepCopier.java | 2 +-
.../java/org/apache/crunch/util/DistCache.java | 2 +-
20 files changed, 72 insertions(+), 57 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
----------------------------------------------------------------------
diff --git a/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java b/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
index b8b9c14..35a74fa 100644
--- a/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
+++ b/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
@@ -20,9 +20,9 @@ package org.apache.crunch.io.hbase;
import java.io.IOException;
import org.apache.commons.lang.builder.HashCodeBuilder;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.SourceTarget;
import org.apache.crunch.hadoop.mapreduce.lib.output.CrunchMultipleOutputs;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.io.MapReduceTarget;
import org.apache.crunch.io.OutputHandler;
import org.apache.crunch.types.PType;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
----------------------------------------------------------------------
diff --git a/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java b/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
index 297680e..9147baf 100644
--- a/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
+++ b/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
@@ -24,6 +24,7 @@ import java.io.IOException;
import java.util.Collections;
import java.util.List;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.MapFn;
import org.apache.crunch.PTable;
import org.apache.crunch.Pair;
@@ -31,7 +32,6 @@ import org.apache.crunch.Pipeline;
import org.apache.crunch.fn.FilterFns;
import org.apache.crunch.impl.mem.MemPipeline;
import org.apache.crunch.impl.mr.MRPipeline;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.test.TemporaryPath;
import org.apache.crunch.test.TemporaryPaths;
import org.apache.crunch.types.writable.Writables;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java b/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java
new file mode 100644
index 0000000..044f600
--- /dev/null
+++ b/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java
@@ -0,0 +1,54 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.crunch;
+
+/**
+ * A {@code RuntimeException} implementation that includes some additional options
+ * for the Crunch execution engine to track reporting status. Clients may
+ * use instances of this class in their own {@code DoFn} implementations.
+ */
+public class CrunchRuntimeException extends RuntimeException {
+
+ private boolean logged = false;
+
+ public CrunchRuntimeException(String msg) {
+ super(msg);
+ }
+
+ public CrunchRuntimeException(Exception e) {
+ super(e);
+ }
+
+ public CrunchRuntimeException(String msg, Exception e) {
+ super(msg, e);
+ }
+
+ /**
+ * Returns true if this exception was written to the debug logs.
+ */
+ public boolean wasLogged() {
+ return logged;
+ }
+
+ /**
+ * Indicate that this exception has been written to the debug logs.
+ */
+ public void markLogged() {
+ this.logged = true;
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java b/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
index 60950f3..40c5863 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
@@ -24,6 +24,7 @@ import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.MapFn;
import org.apache.crunch.PCollection;
import org.apache.crunch.PTable;
@@ -42,7 +43,6 @@ import org.apache.crunch.impl.mr.collect.UnionCollection;
import org.apache.crunch.impl.mr.collect.UnionTable;
import org.apache.crunch.impl.mr.exec.MRExecutor;
import org.apache.crunch.impl.mr.plan.MSCRPlanner;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.impl.mr.run.RuntimeParameters;
import org.apache.crunch.io.At;
import org.apache.crunch.io.ReadableSourceTarget;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
index e068e3c..d271112 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
@@ -19,8 +19,8 @@ package org.apache.crunch.impl.mr.emit;
import java.io.IOException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.Emitter;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.types.Converter;
import org.apache.crunch.hadoop.mapreduce.lib.output.CrunchMultipleOutputs;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
index 88990c2..bc3ae0d 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
@@ -19,8 +19,8 @@ package org.apache.crunch.impl.mr.emit;
import java.io.IOException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.Emitter;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.types.Converter;
import org.apache.hadoop.mapreduce.TaskInputOutputContext;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
index 2de1567..70f0b01 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
@@ -22,6 +22,7 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.hadoop.mapreduce.Mapper;
public class CrunchMapper extends Mapper<Object, Object, Object, Object> {
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
index 89fbd26..12caa86 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
@@ -22,6 +22,7 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.hadoop.mapreduce.Reducer;
public class CrunchReducer extends Reducer<Object, Object, Object, Object> {
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
deleted file mode 100644
index 72e939f..0000000
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.crunch.impl.mr.run;
-
-public class CrunchRuntimeException extends RuntimeException {
-
- private boolean logged = false;
-
- public CrunchRuntimeException(String msg) {
- super(msg);
- }
-
- public CrunchRuntimeException(Exception e) {
- super(e);
- }
-
- public CrunchRuntimeException(String msg, Exception e) {
- super(msg, e);
- }
-
- public boolean wasLogged() {
- return logged;
- }
-
- public void markLogged() {
- this.logged = true;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
index 4ba8bad..3846e36 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
@@ -20,6 +20,7 @@ package org.apache.crunch.impl.mr.run;
import java.io.IOException;
import java.util.List;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.impl.mr.plan.PlanningParameters;
import org.apache.crunch.util.DistCache;
import org.apache.hadoop.conf.Configuration;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
index 1f5124c..ead1d9e 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
@@ -22,6 +22,7 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.DoFn;
import org.apache.crunch.Emitter;
import org.apache.crunch.impl.mr.emit.IntermediateEmitter;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java b/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
index 0ca1ab3..1acbf2d 100644
--- a/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
+++ b/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
@@ -19,12 +19,12 @@ package org.apache.crunch.lib.join;
import java.io.IOException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.DoFn;
import org.apache.crunch.Emitter;
import org.apache.crunch.PTable;
import org.apache.crunch.Pair;
import org.apache.crunch.impl.mr.MRPipeline;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.io.ReadableSourceTarget;
import org.apache.crunch.io.impl.SourcePathTargetImpl;
import org.apache.crunch.types.PType;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java b/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
index 3830616..2d6c573 100644
--- a/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
+++ b/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
@@ -22,8 +22,8 @@ import java.util.Iterator;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.Pipeline;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.crunch.io.ReadableSourceTarget;
public class MaterializableIterable<E> implements Iterable<E> {
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/PTypes.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/PTypes.java b/crunch/src/main/java/org/apache/crunch/types/PTypes.java
index 9533872..1f87874 100644
--- a/crunch/src/main/java/org/apache/crunch/types/PTypes.java
+++ b/crunch/src/main/java/org/apache/crunch/types/PTypes.java
@@ -20,8 +20,8 @@ package org.apache.crunch.types;
import java.math.BigInteger;
import java.nio.ByteBuffer;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.MapFn;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.hadoop.util.ReflectionUtils;
import org.apache.thrift.TBase;
import org.apache.thrift.TDeserializer;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/Protos.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/Protos.java b/crunch/src/main/java/org/apache/crunch/types/Protos.java
index 2de1c11..4cd5068 100644
--- a/crunch/src/main/java/org/apache/crunch/types/Protos.java
+++ b/crunch/src/main/java/org/apache/crunch/types/Protos.java
@@ -20,10 +20,10 @@ package org.apache.crunch.types;
import java.util.Iterator;
import java.util.List;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.DoFn;
import org.apache.crunch.Emitter;
import org.apache.crunch.MapFn;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import org.apache.hadoop.util.ReflectionUtils;
import com.google.common.base.Splitter;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java b/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
index 69fbc92..73b47de 100644
--- a/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
+++ b/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
@@ -21,12 +21,12 @@ import java.io.Serializable;
import java.lang.reflect.Constructor;
import java.util.Map;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.Pair;
import org.apache.crunch.Tuple;
import org.apache.crunch.Tuple3;
import org.apache.crunch.Tuple4;
import org.apache.crunch.TupleN;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
import com.google.common.collect.Maps;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java b/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
index 4b02fc6..2deeddb 100644
--- a/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
+++ b/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
@@ -33,7 +33,7 @@ import org.apache.avro.io.DecoderFactory;
import org.apache.avro.io.EncoderFactory;
import org.apache.avro.specific.SpecificDatumReader;
import org.apache.avro.specific.SpecificDatumWriter;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.types.DeepCopier;
import org.apache.hadoop.conf.Configuration;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java b/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
index 8e2ec6d..79c93be 100644
--- a/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
+++ b/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
@@ -23,7 +23,7 @@ import java.io.IOException;
import java.util.Arrays;
import org.apache.commons.lang.builder.HashCodeBuilder;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableFactories;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java b/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
index ae4614d..84e22e3 100644
--- a/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
+++ b/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
@@ -23,7 +23,7 @@ import java.io.DataInput;
import java.io.DataInputStream;
import java.io.DataOutputStream;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.crunch.types.DeepCopier;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Writable;
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/util/DistCache.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/util/DistCache.java b/crunch/src/main/java/org/apache/crunch/util/DistCache.java
index 20675d2..891cc6c 100644
--- a/crunch/src/main/java/org/apache/crunch/util/DistCache.java
+++ b/crunch/src/main/java/org/apache/crunch/util/DistCache.java
@@ -26,7 +26,7 @@ import java.net.URL;
import java.net.URLDecoder;
import java.util.Enumeration;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.filecache.DistributedCache;
import org.apache.hadoop.fs.FileSystem;