diff --git pom.xml pom.xml
index 7343683..006441c 100644
--- pom.xml
+++ pom.xml
@@ -139,7 +139,7 @@
1.0.1
1.7.5
4.0.4
- 0.3.0-incubating
+ 0.4.0-incubating
1.1
0.2
1.4
diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
index 78e965b..c0755f8 100644
--- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
+++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
@@ -115,6 +115,7 @@
import org.apache.tez.runtime.library.input.ShuffledUnorderedKVInput;
import org.apache.tez.runtime.library.output.OnFileSortedOutput;
import org.apache.tez.runtime.library.output.OnFileUnorderedKVOutput;
+import org.apache.tez.runtime.library.output.OnFileUnorderedPartitionedKVOutput;
/**
* DagUtils. DagUtils is a collection of helper methods to convert
@@ -311,7 +312,7 @@ private EdgeProperty createEdgeProperty(TezEdgeProperty edgeProp) throws IOExcep
case CUSTOM_EDGE:
dataMovementType = DataMovementType.CUSTOM;
- logicalOutputClass = OnFileSortedOutput.class;
+ logicalOutputClass = OnFileUnorderedPartitionedKVOutput.class;
logicalInputClass = ShuffledUnorderedKVInput.class;
EdgeManagerDescriptor edgeDesc = new EdgeManagerDescriptor(
CustomPartitionEdge.class.getName());
@@ -331,7 +332,7 @@ private EdgeProperty createEdgeProperty(TezEdgeProperty edgeProp) throws IOExcep
case CUSTOM_SIMPLE_EDGE:
dataMovementType = DataMovementType.SCATTER_GATHER;
- logicalOutputClass = OnFileSortedOutput.class;
+ logicalOutputClass = OnFileUnorderedPartitionedKVOutput.class;
logicalInputClass = ShuffledUnorderedKVInput.class;
break;