You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2013/07/06 02:30:52 UTC
git commit: TEZ-282. Remove DAGImpl unused vars (bikas)
Updated Branches:
refs/heads/master 44c2e50d5 -> 92228baa7
TEZ-282. Remove DAGImpl unused vars (bikas)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/92228baa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/92228baa
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/92228baa
Branch: refs/heads/master
Commit: 92228baa76edc810377bcd028148414e45cb9ba4
Parents: 44c2e50
Author: Bikas Saha <bi...@apache.org>
Authored: Fri Jul 5 17:27:08 2013 -0700
Committer: Bikas Saha <bi...@apache.org>
Committed: Fri Jul 5 17:27:08 2013 -0700
----------------------------------------------------------------------
.../apache/tez/dag/app/dag/impl/DAGImpl.java | 22 --------------------
1 file changed, 22 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/92228baa/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
index 23bfbd1..9e4f00b 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
@@ -33,8 +33,6 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.classification.InterfaceAudience.Private;
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.security.Credentials;
@@ -142,11 +140,6 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
public final TezConfiguration conf;
private final DAGPlan jobPlan;
- //fields initialized in init
- private FileSystem fs;
- private Path remoteJobSubmitDir;
- public Path remoteJobConfFile;
-
private final List<String> diagnostics = new ArrayList<String>();
private static final DiagnosticsUpdateTransition
@@ -647,16 +640,6 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
new DAGHistoryEvent(dagId, finishEvt));
}
- /**
- * Create the default file System for this job.
- * @param conf the conf object
- * @return the default filesystem for this job
- * @throws IOException
- */
- protected FileSystem getFileSystem(Configuration conf) throws IOException {
- return FileSystem.get(conf);
- }
-
static DAGState checkJobForCompletion(DAGImpl dag) {
if (LOG.isDebugEnabled()) {
LOG.debug("Checking dag completion"
@@ -798,7 +781,6 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
//dag.metrics.preparingJob(dag);
try {
setup(dag);
- dag.fs = dag.getFileSystem(dag.conf);
// If we have no vertices, fail the dag
dag.numVertices = dag.getJobPlan().getVertexCount();
@@ -940,10 +922,6 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
LOG.debug("startJobs: parent=" + path + " child=" + dagIdString);
}
- job.remoteJobSubmitDir =
- FileSystem.get(job.conf).makeQualified(
- new Path(path, dagIdString));
-
// Prepare the TaskAttemptListener server for authentication of Containers
// TaskAttemptListener gets the information via jobTokenSecretManager.
JobTokenIdentifier identifier =