tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-282. Remove DAGImpl unused vars (bikas)
Date Sat, 06 Jul 2013 00:30:52 GMT
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 <bikas@apache.org>
Authored: Fri Jul 5 17:27:08 2013 -0700
Committer: Bikas Saha <bikas@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 =


Mime
View raw message