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/04/29 00:30:09 UTC
svn commit: r1590829 -
/pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/shims/TaskContext.java
Author: cheolsoo
Date: Mon Apr 28 22:30:08 2014
New Revision: 1590829
URL: http://svn.apache.org/r1590829
Log:
PIG-3860: Refactor PigStatusReporter and PigLogger for non-MR execution engine
(Remove tez-related code from TaskContext in hadoop23 shum. It was committed
accidentally.)
Modified:
pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/shims/TaskContext.java
Modified: pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/shims/TaskContext.java
URL: http://svn.apache.org/viewvc/pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/shims/TaskContext.java?rev=1590829&r1=1590828&r2=1590829&view=diff
==============================================================================
--- pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/shims/TaskContext.java (original)
+++ pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/shims/TaskContext.java Mon Apr 28 22:30:08 2014
@@ -20,8 +20,6 @@ package org.apache.pig.backend.hadoop.ex
import org.apache.hadoop.mapreduce.Counter;
import org.apache.hadoop.mapreduce.TaskInputOutputContext;
import org.apache.pig.backend.hadoop.executionengine.fetch.FetchContext;
-import org.apache.tez.common.counters.TezCounter;
-import org.apache.tez.runtime.api.TezProcessorContext;
public class TaskContext<T> {
private T context;
@@ -78,11 +76,6 @@ public class TaskContext<T> {
Counter counter = fetchContext.getCounter(name);
counter.increment(delta);
return true;
- } else if (context instanceof TezProcessorContext) {
- TezProcessorContext tezContext = (TezProcessorContext) context;
- TezCounter counter = tezContext.getCounters().findCounter(name);
- counter.increment(delta);
- return true;
}
return false;
}
@@ -101,11 +94,6 @@ public class TaskContext<T> {
Counter counter = fetchContext.getCounter(group, name);
counter.increment(delta);
return true;
- } else if (context instanceof TezProcessorContext) {
- TezProcessorContext tezContext = (TezProcessorContext) context;
- TezCounter counter = tezContext.getCounters().getGroup(group).findCounter(name);
- counter.increment(delta);
- return true;
}
return false;
}