Index: pom.xml
===================================================================
--- pom.xml (revision 1629103)
+++ pom.xml (working copy)
@@ -151,7 +151,7 @@
1.0.1
1.7.5
4.0.4
- 0.5.0
+ 0.5.1
2.2.0
1.1
0.2
Index: ql/src/java/org/apache/hadoop/hive/ql/exec/AppMasterEventOperator.java
===================================================================
--- ql/src/java/org/apache/hadoop/hive/ql/exec/AppMasterEventOperator.java (revision 1629103)
+++ ql/src/java/org/apache/hadoop/hive/ql/exec/AppMasterEventOperator.java (working copy)
@@ -60,9 +60,6 @@
protected void initDataBuffer(boolean skipPruning) throws HiveException {
buffer = new DataOutputBuffer();
try {
- // where does this go to?
- buffer.writeUTF(((TezContext) TezContext.get()).getTezProcessorContext().getTaskVertexName());
-
// add any other header info
getConf().writeEventHeader(buffer);
Index: ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DynamicPartitionPruner.java
===================================================================
--- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DynamicPartitionPruner.java (revision 1629103)
+++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DynamicPartitionPruner.java (working copy)
@@ -31,6 +31,7 @@
import java.util.Map;
import java.util.Set;
import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.ConcurrentSkipListSet;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicBoolean;
@@ -59,6 +60,7 @@
import org.apache.hadoop.io.BytesWritable;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.tez.dag.api.event.VertexState;
import org.apache.tez.runtime.api.InputInitializerContext;
import org.apache.tez.runtime.api.events.InputInitializerEvent;
@@ -77,12 +79,13 @@
private final BytesWritable writable = new BytesWritable();
- private final BlockingQueue queue =
- new LinkedBlockingQueue();
+ private final BlockingQueue