You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ch...@apache.org on 2014/08/04 21:31:15 UTC

svn commit: r1615734 - in /pig/trunk: CHANGES.txt shims/test/hadoop23/org/apache/pig/test/TezMiniCluster.java

Author: cheolsoo
Date: Mon Aug  4 19:31:15 2014
New Revision: 1615734

URL: http://svn.apache.org/r1615734
Log:
PIG-4101: Lower tez.am.task.max.failed.attempts to 2 from 4 in Tez mini cluster (cheolsoo)

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/shims/test/hadoop23/org/apache/pig/test/TezMiniCluster.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1615734&r1=1615733&r2=1615734&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Mon Aug  4 19:31:15 2014
@@ -52,6 +52,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4101: Lower tez.am.task.max.failed.attempts to 2 from 4 in Tez mini cluster (cheolsoo)
+
 PIG-4099: "ant copypom" failed with "could not find file $PIG_HOME/ivy/pig.pom to copy" (fang fang chen via cheolsoo)
 
 PIG-4098: Vertex Location Hint api update after TEZ-1041 (jeagles via cheolsoo)

Modified: pig/trunk/shims/test/hadoop23/org/apache/pig/test/TezMiniCluster.java
URL: http://svn.apache.org/viewvc/pig/trunk/shims/test/hadoop23/org/apache/pig/test/TezMiniCluster.java?rev=1615734&r1=1615733&r2=1615734&view=diff
==============================================================================
--- pig/trunk/shims/test/hadoop23/org/apache/pig/test/TezMiniCluster.java (original)
+++ pig/trunk/shims/test/hadoop23/org/apache/pig/test/TezMiniCluster.java Mon Aug  4 19:31:15 2014
@@ -122,6 +122,9 @@ public class TezMiniCluster extends Mini
             tez_conf.set("tez.lib.uris", "hdfs:///tez,hdfs:///tez/lib");
             // Set to a lower value so that tests don't get stuck for long because of 1 AM running at a time
             tez_conf.set(TezConfiguration.TEZ_SESSION_AM_DAG_SUBMIT_TIMEOUT_SECS, "20");
+            // Lower the max task attempts to 2 so that negative tests fail
+            // faster. By default, tasks retry 4 times
+            tez_conf.set(TezConfiguration.TEZ_AM_TASK_MAX_FAILED_ATTEMPTS, "2");
             tez_conf.writeXml(new FileOutputStream(TEZ_CONF_FILE));
 
             // Copy tez jars to hdfs