|
@@ -911,6 +911,18 @@
|
|
|
</description>
|
|
|
</property>
|
|
|
|
|
|
+ <property>
|
|
|
+ <name>mapreduce.map.skip.proc-count.auto-incr</name>
|
|
|
+ <value>true</value>
|
|
|
+ <description>The flag which if set to true,
|
|
|
+ SkipBadRecords.COUNTER_MAP_PROCESSED_RECORDS is incremented by
|
|
|
+ MapRunner after invoking the map function. This value must be set
|
|
|
+ to false for applications which process the records asynchronously
|
|
|
+ or buffer the input records. For example streaming. In such cases
|
|
|
+ applications should increment this counter on their own.
|
|
|
+ </description>
|
|
|
+ </property>
|
|
|
+
|
|
|
<property>
|
|
|
<name>mapreduce.reduce.skip.maxgroups</name>
|
|
|
<value>0</value>
|
|
@@ -926,6 +938,18 @@
|
|
|
</description>
|
|
|
</property>
|
|
|
|
|
|
+ <property>
|
|
|
+ <name>mapreduce.reduce.skip.proc-count.auto-incr</name>
|
|
|
+ <value>true</value>
|
|
|
+ <description>The flag which if set to true.
|
|
|
+ SkipBadRecords.COUNTER_REDUCE_PROCESSED_GROUPS is incremented by framework
|
|
|
+ after invoking the reduce function. This value must be set to false for
|
|
|
+ applications which process the records asynchronously or buffer the input
|
|
|
+ records. For example streaming. In such cases applications should increment
|
|
|
+ this counter on their own.
|
|
|
+ </description>
|
|
|
+ </property>
|
|
|
+
|
|
|
<property>
|
|
|
<name>mapreduce.ifile.readahead</name>
|
|
|
<value>true</value>
|