Author: navis
Date: Mon Jul 28 01:56:27 2014
New Revision: 1613869
URL: http://svn.apache.org/r1613869
Log:
HIVE-7017 : Insertion into Parquet tables fails under Tez (Craig Condit reviwed
by Thejas, Navis)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
URL:
http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java?rev=1613869&r1=1613868&r2=1613869&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
(original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
Mon Jul 28 01:56:27 2014
@@ -16,9 +16,9 @@
* limitations under the License.
*/
package org.apache.hadoop.hive.ql.exec.tez;
+
import java.io.IOException;
import java.text.NumberFormat;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
@@ -101,7 +101,7 @@ public class TezProcessor implements Log
private void setupMRLegacyConfigs(TezProcessorContext processorContext) {
// Hive "insert overwrite local directory" uses task id as dir name
// Setting the id in jobconf helps to have the similar dir name as MR
- StringBuilder taskAttemptIdBuilder = new StringBuilder("task");
+ StringBuilder taskAttemptIdBuilder = new StringBuilder("attempt_");
taskAttemptIdBuilder.append(processorContext.getApplicationId().getClusterTimestamp())
.append("_")
.append(jobIdFormat.format(processorContext.getApplicationId().getId()))
