You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/22 13:14:14 UTC
incubator-ignite git commit: # patch by Evans Ye.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-909 [created] 875010dd5
# patch by Evans Ye.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/875010dd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/875010dd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/875010dd
Branch: refs/heads/ignite-909
Commit: 875010dd54073db47b362021699f0ce229c0e88d
Parents: 02f3a12
Author: iveselovskiy <iv...@gridgain.com>
Authored: Fri May 22 14:14:01 2015 +0300
Committer: iveselovskiy <iv...@gridgain.com>
Committed: Fri May 22 14:14:01 2015 +0300
----------------------------------------------------------------------
.../internal/processors/hadoop/v2/HadoopV2Context.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/875010dd/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2Context.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2Context.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2Context.java
index 3f8e2b6..53159b1 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2Context.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/HadoopV2Context.java
@@ -89,12 +89,12 @@ public class HadoopV2Context extends JobContextImpl implements MapContext, Reduc
inputSplit = new FileSplit(new Path(fileBlock.file()), fileBlock.start(), fileBlock.length(), null);
}
- else if (split instanceof HadoopExternalSplit)
- throw new UnsupportedOperationException(); // TODO
- else if (split instanceof HadoopSplitWrapper)
- inputSplit = (InputSplit) HadoopUtils.unwrapSplit((HadoopSplitWrapper) split);
else
- throw new IllegalStateException();
+ try {
+ inputSplit = (InputSplit) ((HadoopV2TaskContext)ctx).getNativeSplit(split);
+ } catch (IgniteCheckedException e) {
+ throw new IllegalStateException(e);
+ }
}
return inputSplit;