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 <[email protected]> Authored: Tue Dec 18 09:22:28 2012 -0800 Committer: Josh Wills <[email protected]> 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;
