Repository: ignite Updated Branches: refs/heads/master 82dd91288 -> d6d42c2a1
IGNITE-4514: Hadoop: fixed intermittent intermittent failure in HadoopCommandLineTest.testHiveCommandLine. This closes #1397. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d6d42c2a Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d6d42c2a Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d6d42c2a Branch: refs/heads/master Commit: d6d42c2a17b7cf53a71d59931b2cf838bd8116c9 Parents: 82dd912 Author: Ivan Veselovskiy <iveselovs...@gridgain.com> Authored: Mon Jan 16 16:46:20 2017 +0300 Committer: devozerov <voze...@gridgain.com> Committed: Mon Jan 16 16:46:20 2017 +0300 ---------------------------------------------------------------------- .../processors/hadoop/impl/v2/HadoopV2TaskContext.java | 7 ------- 1 file changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d6d42c2a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java index d328550..5229590 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2TaskContext.java @@ -42,7 +42,6 @@ import org.apache.hadoop.util.ReflectionUtils; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.hadoop.io.PartiallyRawComparator; import org.apache.ignite.hadoop.io.TextPartiallyRawComparator; -import org.apache.ignite.internal.processors.hadoop.HadoopClassLoader; import org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils; import org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit; import org.apache.ignite.internal.processors.hadoop.HadoopInputSplit; @@ -508,12 +507,6 @@ public class HadoopV2TaskContext extends HadoopTaskContext { FileSystem fs; try { - // This assertion uses .startsWith() instead of .equals() because task class loaders may - // be reused between tasks of the same job. - assert ((HadoopClassLoader)getClass().getClassLoader()).name() - .startsWith(HadoopClassLoader.nameForTask(taskInfo(), true)); - - // We also cache Fs there, all them will be cleared explicitly upon the Job end. fs = fileSystemForMrUserWithCaching(jobDir.toUri(), jobConf(), fsMap); } catch (IOException e) {
