You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2013/04/19 01:54:28 UTC
svn commit: r1469642 [1/36] - in /incubator/tez/branches/TEZ-1: ./
example_jobs/ example_jobs/sampleInput/ example_jobs/wc_mr_6m_1r/
example_jobs/wc_mrr_6m_3r_3r/ ljr_helper/ tez-common/ tez-common/src/
tez-common/src/main/ tez-common/src/main/java/ te...
Author: hitesh
Date: Thu Apr 18 23:54:18 2013
New Revision: 1469642
URL: http://svn.apache.org/r1469642
Log:
Adding initial work on DAG Application Master
Added:
incubator/tez/branches/TEZ-1/
incubator/tez/branches/TEZ-1/INSTALL.txt (with props)
incubator/tez/branches/TEZ-1/README.md
incubator/tez/branches/TEZ-1/example_jobs/
incubator/tez/branches/TEZ-1/example_jobs/README (with props)
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/capacity-scheduler.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/core-site.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/hdfs-site.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/log4j.properties (with props)
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/mapred-site.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/sampleInput/yarn-site.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/
incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/appTokens (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.jar (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.split (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.splitmetainfo
incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/appTokens (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/job.jar (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/job.split (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/job.splitmetainfo
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/job.xml (with props)
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/job.xml_reduce1
incubator/tez/branches/TEZ-1/example_jobs/wc_mrr_6m_3r_3r/job.xml_reduce2
incubator/tez/branches/TEZ-1/ljr_helper/
incubator/tez/branches/TEZ-1/ljr_helper/MR_LJR_revoke.patch (with props)
incubator/tez/branches/TEZ-1/ljr_helper/README.md
incubator/tez/branches/TEZ-1/ljr_helper/ln_mrx_jars.sh (with props)
incubator/tez/branches/TEZ-1/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-common/
incubator/tez/branches/TEZ-1/tez-common/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-common/src/
incubator/tez/branches/TEZ-1/tez-common/src/main/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/Constants.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/IDUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/InputSpec.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/OutputSpec.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/TezJobConfig.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/TezTask.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/TezTaskReporter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/TezTaskStatus.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/AbstractCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/AbstractCounterGroup.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/AbstractCounters.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/CounterGroup.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/CounterGroupBase.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/CounterGroupFactory.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/DAGCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/FileSystemCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/FileSystemCounterGroup.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/FrameworkCounterGroup.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/GenericCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/JobCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/LimitExceededException.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/Limits.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/ResourceBundles.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/TaskCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/TezCounter.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/common/counters/TezCounters.java (with props)
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/records/
incubator/tez/branches/TEZ-1/tez-common/src/main/java/org/apache/tez/records/TezContainerId.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/
incubator/tez/branches/TEZ-1/tez-dag-api/
incubator/tez/branches/TEZ-1/tez-dag-api/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/DAG.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/DAGConfiguration.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/DAGLocationHint.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/Edge.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/EdgeProperty.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/TezConfiguration.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/TezException.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/Vertex.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/VertexLocationHint.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/client/
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/client/DAGStatus.java (with props)
incubator/tez/branches/TEZ-1/tez-dag-api/src/main/java/org/apache/tez/dag/api/client/VertexStatus.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/
incubator/tez/branches/TEZ-1/tez-dag/src/main/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/CustomOutputCommitter.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/MRVertexOutputCommitter.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/MapReduceChildJVM2.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/TezMRTypeConverter.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/WrappedJvmID.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/WrappedPeriodicStatsAccumulator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/WrappedProgressSplitsBlock.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/YarnOutputFiles.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/hadoop/mapred/YarnTezDagChild.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/client/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/client/impl/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/client/impl/TezBuilderUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/impl/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/impl/NullVertexOutputCommitter.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/impl/VertexContext.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/impl/VertexOutputCommitter.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/records/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/records/AMInfo.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/records/TaskAttemptReport.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/records/TaskAttemptState.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/records/TaskReport.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/api/records/TaskState.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/AppContext.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/ContainerHeartbeatHandler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/ControlledClock.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/HeartbeatHandlerBase.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/JobEndNotifier.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/MRClientSecurityInfo.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListener.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskHeartbeatHandler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/client/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/client/ClientService.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/client/impl/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/client/impl/TezClientService.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/client/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGReport.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGState.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/JobStateInternal.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/Task.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskAttempt.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskAttemptStateInternal.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskStateInternal.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/Vertex.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/VertexScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/VertexState.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventCounterUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventDiagnosticsUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventSchedulerUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventVertexCompleted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGFinishEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DiagnosableEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventContainerTerminated.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventContainerTerminating.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventDiagnosticsUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventFailRequest.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventKillRequest.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventNodeFailed.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventOutputConsumable.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventSchedule.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStartedRemotely.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStatusUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventTAUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventSourceTaskAttemptCompleted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventSourceVertexStarted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskAttemptCompleted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskAttemptFetchFailure.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskCompleted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskReschedule.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BipartiteSlowStartVertexScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGSchedulerMRR.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGSchedulerNaturalOrder.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/ImmediateStartVertexScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImplHelpers.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/dag/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncher.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/local/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/local/LocalContainerRequestor.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/local/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMRMClient.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMRMClientAsync.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMRMClientImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventContainerCompleted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventContainersAllocated.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventDeallocateContainer.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventNodeBlacklisted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTAEnded.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTALaunchRequest.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/ContainerAllocator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/ContainerRequestor.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorLaunchRequestEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorStopRequestEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/RMCommunicator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/RMCommunicatorEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/RMCommunicatorEventContainerDeAllocateRequest.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/RMCommunicatorEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/RMContainerRequestor.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainer.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventAssignTA.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventCompleted.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventLaunchFailed.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventLaunchRequest.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventLaunched.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventNodeFailed.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventStopFailed.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventTASucceeded.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerHelpers.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerMap.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerState.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerTask.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNode.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventContainerAllocated.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventNodeCountUpdated.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventTaskAttemptEnded.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventTaskAttemptSucceeded.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventType.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeMap.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeState.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/rm/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/security/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/security/authorize/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/security/authorize/ClientHSPolicyProvider.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/security/authorize/MRAMPolicyProvider.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/security/authorize/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/DataStatistics.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/DefaultSpeculator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/ExponentiallySmoothedTaskRuntimeEstimator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/LegacyTaskRuntimeEstimator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/NullTaskRuntimesEngine.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/Speculator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/SpeculatorEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/StartEndTimesBase.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/TaskRuntimeEstimator.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/TaskSpeculationPredicate.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/speculate/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/TaskAttemptCleanupEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/TaskCleaner.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/TaskCleanerContainerCompletedEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/TaskCleanerImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/TaskCleanupEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/taskclean/package-info.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/main/resources/
incubator/tez/branches/TEZ-1/tez-dag/src/main/resources/META-INF/
incubator/tez/branches/TEZ-1/tez-dag/src/main/resources/META-INF/services/
incubator/tez/branches/TEZ-1/tez-dag/src/main/resources/META-INF/services/org.apache.hadoop.security.SecurityInfo
incubator/tez/branches/TEZ-1/tez-dag/src/test/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/api/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/api/TestDAGLocationHint.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/api/TestVertexLocationHint.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/app/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/app/rm/
incubator/tez/branches/TEZ-1/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/test/resources/
incubator/tez/branches/TEZ-1/tez-dag/src/test/resources/krb5.conf (with props)
incubator/tez/branches/TEZ-1/tez-dag/src/test/resources/log4j.properties (with props)
incubator/tez/branches/TEZ-1/tez-dist/
incubator/tez/branches/TEZ-1/tez-dist/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-dist/src/
incubator/tez/branches/TEZ-1/tez-dist/src/main/
incubator/tez/branches/TEZ-1/tez-dist/src/main/assembly/
incubator/tez/branches/TEZ-1/tez-dist/src/main/assembly/tez-dist.xml (with props)
incubator/tez/branches/TEZ-1/tez-engine/
incubator/tez/branches/TEZ-1/tez-engine-api/
incubator/tez/branches/TEZ-1/tez-engine-api/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/Input.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/Master.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/Output.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/Partitioner.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/Processor.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/api/Task.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/OutputContext.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezDAGID.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezDependentTaskCompletionEvent.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezID.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezTaskAttemptID.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezTaskDependencyCompletionEventsUpdate.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezTaskID.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezTaskType.java (with props)
incubator/tez/branches/TEZ-1/tez-engine-api/src/main/java/org/apache/tez/engine/records/TezVertexID.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/
incubator/tez/branches/TEZ-1/tez-engine/src/main/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/hadoop/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/hadoop/io/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/hadoop/io/BufferUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/hadoop/io/HashComparator.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/common/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/common/ContainerTask.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/common/TezEngineTask.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/ConfigUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/YARNMaster.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/combine/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/combine/CombineInput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/combine/CombineOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/localshuffle/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/localshuffle/LocalShuffle.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/security/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/security/DelegationTokenRenewal.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/security/JobTokenIdentifier.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/security/JobTokenSecretManager.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/security/JobTokenSelector.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/security/SecureShuffleUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/EventFetcher.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/ExceptionReporter.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/Fetcher.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/InMemoryReader.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/InMemoryWriter.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/MapHost.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/MapOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/MergeManager.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/MergeThread.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/Shuffle.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/ShuffleClientMetrics.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/ShuffleHeader.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/impl/ShuffleScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/server/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/shuffle/server/ShuffleHandler.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/SortingOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/ExternalSorter.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/IFile.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/IFileInputStream.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/IFileOutputStream.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/PipelinedSorter.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/TezIndexRecord.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/TezMerger.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/TezRawKeyValueIterator.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/TezSpillRecord.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/dflt/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/dflt/DefaultSorter.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/dflt/InMemoryShuffleSorter.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/sort/impl/dflt/SortBufferInputStream.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/impl/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/impl/CombineValuesIterator.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/impl/ValuesIterator.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/local/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/local/output/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/local/output/TezLocalTaskOutputFiles.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/local/output/TezTaskOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/common/task/local/output/TezTaskOutputFiles.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/input/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/input/LocalMergedInput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/input/ShuffledMergedInput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/output/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/output/InMemorySortedOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/output/LocalOnFileSorterOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/lib/output/OnFileSortedOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/InputFactory.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/OutputFactory.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/ProcessorFactory.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/TaskFactory.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/TezEngineFactory.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/runtime/TezEngineFactoryImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/task/
incubator/tez/branches/TEZ-1/tez-engine/src/main/java/org/apache/tez/engine/task/RuntimeTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/dev-support/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/dev-support/findbugs-exclude.xml (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/Join.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/RandomTextWriter.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/RandomWriter.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/SecondarySort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/Sort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCount.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCountMRRTest.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/package.html (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/.gitignore
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/100TBTaskTime.png (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/1PBTaskTime.png (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/1TBTaskTime.png (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/500GBTaskTime.png (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/Yahoo2009.tex
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/2009-write-up/tera.bib
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/GenSort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/Random16.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraChecksum.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraGen.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraInputFormat.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraOutputFormat.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraScheduler.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraSort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/TeraValidate.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/Unsigned16.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/job_history_summary.py (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/terasort/package.html (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/apache/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/apache/tez/mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/apache/tez/mapreduce/examples/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/apache/tez/mapreduce/examples/terasort/
incubator/tez/branches/TEZ-1/tez-mapreduce-examples/src/test/java/org/apache/tez/mapreduce/examples/terasort/TestTeraSort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapred/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapred/LocalClientProtocolProvider.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapred/LocalJobRunner.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapred/LocalJobRunnerMetrics.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapreduce/split/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReaderTez.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/ContainerContext.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/DeprecatedKeys.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/IDConverter.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRConfig.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRJobConfig.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRTaskStatus.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRTaskType.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfigUtil.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/TezTaskUmbilicalProtocol.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/TezTypeConverters.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/JobContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/MRCounters.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/TaskAttemptContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/JobContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/MapContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/ReduceContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/TaskAttemptContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/TaskInputOutputContextImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/records/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/records/ProceedToCompletionResponse.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/input/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/input/SimpleInput.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/SimpleOutput.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/MRPartitioner.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/FileSystemStatisticsUpdater.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/GcTimeUpdater.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/MRTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/MRTaskReporter.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/TezTaskReporterImpl.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/reduce/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/reduce/ReduceProcessor.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/FinalTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/InitialTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/InitialTaskWithInMemSort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/InitialTaskWithLocalSort.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/IntermediateTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/LocalFinalTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/MapOnlyTask.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/impl/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/impl/YarnOutputFiles.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/TestTaskModules.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/TestUmbilicalProtocol.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/TezTestUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/processor/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/processor/MapUtils.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/processor/map/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/processor/map/TestMapProcessor.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/processor/reduce/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/processor/reduce/TestReduceProcessor.java (with props)
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/resources/
incubator/tez/branches/TEZ-1/tez-mapreduce/src/test/resources/log4j.properties (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/
incubator/tez/branches/TEZ-1/tez-yarn-client/pom.xml (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ClientCache.java (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ClientServiceDelegate.java (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/NotRunningJob.java (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YARNRunner.java (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YarnTezClientProtocolProvider.java (with props)
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/resources/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/resources/META-INF/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/resources/META-INF/services/
incubator/tez/branches/TEZ-1/tez-yarn-client/src/main/resources/META-INF/services/org.apache.hadoop.mapreduce.protocol.ClientProtocolProvider
Added: incubator/tez/branches/TEZ-1/INSTALL.txt
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/INSTALL.txt?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/INSTALL.txt (added)
+++ incubator/tez/branches/TEZ-1/INSTALL.txt Thu Apr 18 23:54:18 2013
@@ -0,0 +1,33 @@
+How to run MR on TEZ
+=======================
+
+Tez provides an ApplicationMaster that can run MR or MRR jobs. There is a
+translation layer implemented ( may have bugs so please file JIRAs if you
+come across any issues ) that allows a user to run an MR job against the TEZ
+DAG ApplicationMaster.
+
+NOTE: Due to some quirks, all jobs will show an IOException and a failure at
+the end. Please look at the YARN ResourceManager UI to check the correct result
+of the job.
+
+Install/Deploy Instructions
+===========================
+
+1) Deploy Apache Hadoop using the 3.0.0-SNAPSHOT from trunk.
+2) Copy the tez jars and their dependencies from $TEZ_SRC/tez-dist/target/tez-0.2.0-SNAPSHOT/
+ either into $HADOOP_PREFIX/share/hadoop/common/lib/ or modify HADOOP_CLASSPATH
+ in hadoop-env.sh to point to the location where the TEZ jars and dependencies
+ can be found.
+3) Modify mapred-site.xml to change "mapreduce.framework.name" property from its
+ default value of "yarn" to "yarn-tez"
+4) Submit a MR job as you normally would using something like:
+
+$HADOOP_PREFIX/bin/hadoop jar hadoop-mapreduce-client-jobclient-3.0.0-SNAPSHOT-tests.jar sleep -mt 1 -rt 1 -m 1 -r 1
+
+This will use the TEZ DAG ApplicationMaster to run the MR job. This can be
+verified by looking at the AM's logs from the YARN ResourceManager UI.
+
+5) There is a basic example of using an MRR job in the tez-mapreduce-examples.jar. Refer to WordCountMRRTest.java
+in the source code. To run this example:
+
+$HADOOP_PREFIX/bin/hadoop jar tez-mapreduce-examples-0.2.0-SNAPSHOT.jar wordcountmrrtest <in> <out>
Propchange: incubator/tez/branches/TEZ-1/INSTALL.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/README.md
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/README.md?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/README.md (added)
+++ incubator/tez/branches/TEZ-1/README.md Thu Apr 18 23:54:18 2013
@@ -0,0 +1,18 @@
+tez
+===
+
+tez is a generic data-processing pipeline engine envisioned as a low-level engine for higher abstractions
+such as Apache Hadoop Map-Reduce, Apache Pig, Apache Hive etc.
+
+At it's heart, tez is very simple and has just two components:
+
+* The data-processing pipeline engine where-in one can plug-in input, processing and output implementations to
+ perform arbitrary data-processing. Every 'task' in tez has the following:
+ - Input to consume key/value pairs from.
+ - Processor to process them.
+ - Output to collect the processed key/value pairs.
+
+
+* A master for the data-processing application, where-by one can put together arbitrary data-processing 'tasks'
+ described above into a task-DAG to process data as desired.
+ The generic master is implemented as a Apache Hadoop YARN ApplicationMaster.
Added: incubator/tez/branches/TEZ-1/example_jobs/README
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/README?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/README (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/README Thu Apr 18 23:54:18 2013
@@ -0,0 +1,21 @@
+Remove this entire hierarchy once it's possible to submit jobs via a client.
+
+--- Usage
+MR job
+ JOB_DIR=wc_mr_6m_1r
+ HDFS_JOB_DIR=dagTest
+ CLI_OPTION=mr
+
+MRR job
+ JOB_DIR=wc_mrr_6m_3r_3r
+ HDFS_JOB_DIR=mrrTests
+ CLI_OPTION=mrr
+
+- Steps
+Copy the contents of JOB_DIR to HDFS path /user/${user}/.staging/${HDFS_JOB_DIR}
+Copy 'sampleInput' into /user/${user}/input
+Ensure the directroy /user/${user}/out101 does not exist.
+Copy job.xml from ${JOB_DIR} to PWD
+Command to execute (Replace paramaters)
+/Users/sseth/work2/hortonworks/mrx/run/deploydir/bin/hadoop jar /Users/sseth/work2/hortonworks/mrx/run/deploydir/share/hadoop/yarn/hadoop-yarn-applications-unmanaged-am-launcher-3.0.0-SNAPSHOT.jar -cmd "java org.apache.tez.dag.app.DAGAppMaster -predefined ${CLI_OPTION}"
+
Propchange: incubator/tez/branches/TEZ-1/example_jobs/README
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/capacity-scheduler.xml
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/sampleInput/capacity-scheduler.xml?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/sampleInput/capacity-scheduler.xml (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/sampleInput/capacity-scheduler.xml Thu Apr 18 23:54:18 2013
@@ -0,0 +1,86 @@
+<configuration>
+
+ <property>
+ <name>yarn.scheduler.capacity.maximum-applications</name>
+ <value>10000</value>
+ <description>
+ Maximum number of applications that can be pending and running.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.maximum-am-resource-percent</name>
+ <value>0.1</value>
+ <description>
+ Maximum percent of resources in the cluster which can be used to run
+ application masters i.e. controls number of concurrent running
+ applications.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.queues</name>
+ <value>default</value>
+ <description>
+ The queues at the this level (root is the root queue).
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.default.capacity</name>
+ <value>100</value>
+ <description>Default queue target capacity.</description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.default.user-limit-factor</name>
+ <value>1</value>
+ <description>
+ Default queue user limit a percentage from 0.0 to 1.0.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.default.maximum-capacity</name>
+ <value>100</value>
+ <description>
+ The maximum capacity of the default queue.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.default.state</name>
+ <value>RUNNING</value>
+ <description>
+ The state of the default queue. State can be one of RUNNING or STOPPED.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.default.acl_submit_applications</name>
+ <value>*</value>
+ <description>
+ The ACL of who can submit jobs to the default queue.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.root.default.acl_administer_queue</name>
+ <value>*</value>
+ <description>
+ The ACL of who can administer jobs on the default queue.
+ </description>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.capacity.node-locality-delay</name>
+ <value>-1</value>
+ <description>
+ Number of missed scheduling opportunities after which the CapacityScheduler
+ attempts to schedule rack-local containers.
+ Typically this should be set to number of racks in the cluster, this
+ feature is disabled by default, set to -1.
+ </description>
+ </property>
+
+</configuration>
Propchange: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/capacity-scheduler.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/core-site.xml
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/sampleInput/core-site.xml?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/sampleInput/core-site.xml (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/sampleInput/core-site.xml Thu Apr 18 23:54:18 2013
@@ -0,0 +1,18 @@
+<configuration>
+ <property>
+ <name>fs.defaultFS</name>
+ <value>hdfs://localhost:8020</value>
+ </property>
+
+ <property>
+ <name>hadoop.tmp.dir</name>
+ <value>/hadoopWorkDirMrx/tmp/hadoop-${user.name}</value>
+ <!--value>/Users/sseth/hadoopDeployData/tmp/hadoop-${user.name}</value-->
+ </property>
+
+ <property>
+ <name>fs.permissions.umask-mode</name>
+ <value>022</value>
+ </property>
+
+</configuration>
Propchange: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/core-site.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/hdfs-site.xml
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/sampleInput/hdfs-site.xml?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/sampleInput/hdfs-site.xml (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/sampleInput/hdfs-site.xml Thu Apr 18 23:54:18 2013
@@ -0,0 +1,22 @@
+<configuration>
+ <property>
+ <name>dfs.namenode.name.dir</name>
+ <value>/hadoopWorkDirMrx/var/hdfs/name</value>
+ </property>
+
+ <property>
+ <name>dfs.datanode.data.dir</name>
+ <value>/hadoopWorkDirMrx/var/hdfs/data</value>
+ </property>
+
+ <property>
+ <name>dfs.block.size</name>
+ <value>268435456</value>
+ </property>
+
+ <property>
+ <name>dfs.replication</name>
+ <value>3</value>
+ </property>
+
+</configuration>
Propchange: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/hdfs-site.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/log4j.properties
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/sampleInput/log4j.properties?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/sampleInput/log4j.properties (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/sampleInput/log4j.properties Thu Apr 18 23:54:18 2013
@@ -0,0 +1,212 @@
+# Copyright 2011 The Apache Software Foundation
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# Define some default values that can be overridden by system properties
+hadoop.root.logger=INFO,console
+hadoop.log.dir=.
+hadoop.log.file=hadoop.log
+
+# Define the root logger to the system property "hadoop.root.logger".
+log4j.rootLogger=${hadoop.root.logger}, EventCounter
+
+# Logging Threshold
+log4j.threshold=ALL
+
+# Null Appender
+log4j.appender.NullAppender=org.apache.log4j.varia.NullAppender
+
+#
+# Rolling File Appender - cap space usage at 5gb.
+#
+hadoop.log.maxfilesize=256MB
+hadoop.log.maxbackupindex=20
+log4j.appender.RFA=org.apache.log4j.RollingFileAppender
+log4j.appender.RFA.File=${hadoop.log.dir}/${hadoop.log.file}
+
+log4j.appender.RFA.MaxFileSize=${hadoop.log.maxfilesize}
+log4j.appender.RFA.MaxBackupIndex=${hadoop.log.maxbackupindex}
+
+log4j.appender.RFA.layout=org.apache.log4j.PatternLayout
+
+# Pattern format: Date LogLevel LoggerName LogMessage
+log4j.appender.RFA.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
+# Debugging Pattern format
+#log4j.appender.RFA.layout.ConversionPattern=%d{ISO8601} %-5p %c{2} (%F:%M(%L)) - %m%n
+
+
+#
+# Daily Rolling File Appender
+#
+
+log4j.appender.DRFA=org.apache.log4j.DailyRollingFileAppender
+log4j.appender.DRFA.File=${hadoop.log.dir}/${hadoop.log.file}
+
+# Rollver at midnight
+log4j.appender.DRFA.DatePattern=.yyyy-MM-dd
+
+# 30-day backup
+#log4j.appender.DRFA.MaxBackupIndex=30
+log4j.appender.DRFA.layout=org.apache.log4j.PatternLayout
+
+# Pattern format: Date LogLevel LoggerName LogMessage
+log4j.appender.DRFA.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
+# Debugging Pattern format
+#log4j.appender.DRFA.layout.ConversionPattern=%d{ISO8601} %-5p %c{2} (%F:%M(%L)) - %m%n
+
+
+#
+# console
+# Add "console" to rootlogger above if you want to use this
+#
+
+log4j.appender.console=org.apache.log4j.ConsoleAppender
+log4j.appender.console.target=System.err
+log4j.appender.console.layout=org.apache.log4j.PatternLayout
+log4j.appender.console.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %p %c{2}: %m%n
+
+#
+# TaskLog Appender
+#
+
+#Default values
+hadoop.tasklog.taskid=null
+hadoop.tasklog.iscleanup=false
+hadoop.tasklog.noKeepSplits=4
+hadoop.tasklog.totalLogFileSize=100
+hadoop.tasklog.purgeLogSplits=true
+hadoop.tasklog.logsRetainHours=12
+
+log4j.appender.TLA=org.apache.hadoop.mapred.TaskLogAppender
+log4j.appender.TLA.taskId=${hadoop.tasklog.taskid}
+log4j.appender.TLA.isCleanup=${hadoop.tasklog.iscleanup}
+log4j.appender.TLA.totalLogFileSize=${hadoop.tasklog.totalLogFileSize}
+
+log4j.appender.TLA.layout=org.apache.log4j.PatternLayout
+log4j.appender.TLA.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
+
+#
+#Security appender
+#
+hadoop.security.logger=INFO,NullAppender
+hadoop.security.log.maxfilesize=256MB
+hadoop.security.log.maxbackupindex=20
+log4j.category.SecurityLogger=${hadoop.security.logger}
+hadoop.security.log.file=SecurityAuth.audit
+log4j.appender.RFAS=org.apache.log4j.RollingFileAppender
+log4j.appender.RFAS.File=${hadoop.log.dir}/${hadoop.security.log.file}
+log4j.appender.RFAS.layout=org.apache.log4j.PatternLayout
+log4j.appender.RFAS.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
+log4j.appender.RFAS.MaxFileSize=${hadoop.security.log.maxfilesize}
+log4j.appender.RFAS.MaxBackupIndex=${hadoop.security.log.maxbackupindex}
+
+#
+# Daily Rolling Security appender
+#
+log4j.appender.DRFAS=org.apache.log4j.DailyRollingFileAppender
+log4j.appender.DRFAS.File=${hadoop.log.dir}/${hadoop.security.log.file}
+log4j.appender.DRFAS.layout=org.apache.log4j.PatternLayout
+log4j.appender.DRFAS.layout.ConversionPattern=%d{ISO8601} %p %c: %m%n
+log4j.appender.DRFAS.DatePattern=.yyyy-MM-dd
+
+#
+# hdfs audit logging
+#
+hdfs.audit.logger=INFO,NullAppender
+hdfs.audit.log.maxfilesize=256MB
+hdfs.audit.log.maxbackupindex=20
+log4j.logger.org.apache.hadoop.hdfs.server.namenode.FSNamesystem.audit=${hdfs.audit.logger}
+log4j.additivity.org.apache.hadoop.hdfs.server.namenode.FSNamesystem.audit=false
+log4j.appender.RFAAUDIT=org.apache.log4j.RollingFileAppender
+log4j.appender.RFAAUDIT.File=${hadoop.log.dir}/hdfs-audit.log
+log4j.appender.RFAAUDIT.layout=org.apache.log4j.PatternLayout
+log4j.appender.RFAAUDIT.layout.ConversionPattern=%d{ISO8601} %p %c{2}: %m%n
+log4j.appender.RFAAUDIT.MaxFileSize=${hdfs.audit.log.maxfilesize}
+log4j.appender.RFAAUDIT.MaxBackupIndex=${hdfs.audit.log.maxbackupindex}
+
+#
+# mapred audit logging
+#
+mapred.audit.logger=INFO,NullAppender
+mapred.audit.log.maxfilesize=256MB
+mapred.audit.log.maxbackupindex=20
+log4j.logger.org.apache.hadoop.mapred.AuditLogger=${mapred.audit.logger}
+log4j.additivity.org.apache.hadoop.mapred.AuditLogger=false
+log4j.appender.MRAUDIT=org.apache.log4j.RollingFileAppender
+log4j.appender.MRAUDIT.File=${hadoop.log.dir}/mapred-audit.log
+log4j.appender.MRAUDIT.layout=org.apache.log4j.PatternLayout
+log4j.appender.MRAUDIT.layout.ConversionPattern=%d{ISO8601} %p %c{2}: %m%n
+log4j.appender.MRAUDIT.MaxFileSize=${mapred.audit.log.maxfilesize}
+log4j.appender.MRAUDIT.MaxBackupIndex=${mapred.audit.log.maxbackupindex}
+
+# Custom Logging levels
+
+#log4j.logger.org.apache.hadoop.mapred.JobTracker=DEBUG
+#log4j.logger.org.apache.hadoop.mapred.TaskTracker=DEBUG
+#log4j.logger.org.apache.hadoop.hdfs.server.namenode.FSNamesystem.audit=DEBUG
+
+# Jets3t library
+log4j.logger.org.jets3t.service.impl.rest.httpclient.RestS3Service=ERROR
+
+#
+# Event Counter Appender
+# Sends counts of logging messages at different severity levels to Hadoop Metrics.
+#
+log4j.appender.EventCounter=org.apache.hadoop.log.metrics.EventCounter
+
+#
+# Job Summary Appender
+#
+# Use following logger to send summary to separate file defined by
+# hadoop.mapreduce.jobsummary.log.file :
+# hadoop.mapreduce.jobsummary.logger=INFO,JSA
+#
+hadoop.mapreduce.jobsummary.logger=${hadoop.root.logger}
+hadoop.mapreduce.jobsummary.log.file=hadoop-mapreduce.jobsummary.log
+hadoop.mapreduce.jobsummary.log.maxfilesize=256MB
+hadoop.mapreduce.jobsummary.log.maxbackupindex=20
+log4j.appender.JSA=org.apache.log4j.RollingFileAppender
+log4j.appender.JSA.File=${hadoop.log.dir}/${hadoop.mapreduce.jobsummary.log.file}
+log4j.appender.JSA.MaxFileSize=${hadoop.mapreduce.jobsummary.log.maxfilesize}
+log4j.appender.JSA.MaxBackupIndex=${hadoop.mapreduce.jobsummary.log.maxbackupindex}
+log4j.appender.JSA.layout=org.apache.log4j.PatternLayout
+log4j.appender.JSA.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %p %c{2}: %m%n
+log4j.logger.org.apache.hadoop.mapred.JobInProgress$JobSummary=${hadoop.mapreduce.jobsummary.logger}
+log4j.additivity.org.apache.hadoop.mapred.JobInProgress$JobSummary=false
+
+#
+# Yarn ResourceManager Application Summary Log
+#
+# Set the ResourceManager summary log filename
+#yarn.server.resourcemanager.appsummary.log.file=rm-appsummary.log
+# Set the ResourceManager summary log level and appender
+#yarn.server.resourcemanager.appsummary.logger=INFO,RMSUMMARY
+
+# Appender for ResourceManager Application Summary Log
+# Requires the following properties to be set
+# - hadoop.log.dir (Hadoop Log directory)
+# - yarn.server.resourcemanager.appsummary.log.file (resource manager app summary log filename)
+# - yarn.server.resourcemanager.appsummary.logger (resource manager app summary log level and appender)
+
+#log4j.logger.org.apache.hadoop.yarn.server.resourcemanager.RMAppManager$ApplicationSummary=${yarn.server.resourcemanager.appsummary.logger}
+#log4j.additivity.org.apache.hadoop.yarn.server.resourcemanager.RMAppManager$ApplicationSummary=false
+#log4j.appender.RMSUMMARY=org.apache.log4j.RollingFileAppender
+#log4j.appender.RMSUMMARY.File=${hadoop.log.dir}/${yarn.server.resourcemanager.appsummary.log.file}
+#log4j.appender.RMSUMMARY.MaxFileSize=256MB
+#log4j.appender.RMSUMMARY.MaxBackupIndex=20
+#log4j.appender.RMSUMMARY.layout=org.apache.log4j.PatternLayout
+#log4j.appender.RMSUMMARY.layout.ConversionPattern=%d{ISO8601} %p %c{2}: %m%n
Propchange: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/log4j.properties
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/mapred-site.xml
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/sampleInput/mapred-site.xml?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/sampleInput/mapred-site.xml (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/sampleInput/mapred-site.xml Thu Apr 18 23:54:18 2013
@@ -0,0 +1,94 @@
+<configuration>
+
+ <!--yarn.app.mapreduce.am.staging-dir-->
+ <property>
+ <name>mapreduce.framework.name</name>
+ <value>yarn</value>
+ </property>
+
+ <!--property>
+ <name>mapreduce.framework.name</name>
+ <value>yarn-tez</value>
+ </property>
+ <property>
+ <name>mapreduce.application.classpath</name>
+ <value>/Users/sseth/work2/hortonworks/mrx/run/mrxDir/*:/Users/sseth/work2/hortonworks/mrx/run/mrxDir/lib/*</value>
+ </property>
+ <property>
+ <name>yarn.app.mapreduce.am.scheduler.reuse.enable</name>
+ <value>false</value>
+ </property>
+ <property>
+ <name>yarn.app.mapreduce.am.scheduler.reuse.max-attempts-per-container</name>
+ <value>-1</value>
+ </property-->
+
+
+ <property>
+ <name>mapred.child.java.opts</name>
+ <!--value>-server -Xmx200m -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=/Users/sseth/work2/hortonworks/mrx/run/dumps -XX:+PrintGCDetails -verbose:gc -XX:+PrintGCTimeStamps</value-->
+ <value>-server -Xmx200m</value>
+ </property>
+
+ <property>
+ <name>mapreduce.map.memory.mb</name>
+ <value>1024</value>
+ </property>
+
+ <property>
+ <name>mapreduce.reduce.memory.mb</name>
+ <value>1024</value>
+ </property>
+
+ <property>
+ <name>yarn.app.mapreduce.am.resource.mb</name>
+ <value>1024</value>
+ </property>
+
+ <property>
+ <name>yarn.app.mapreduce.am.staging-dir</name>
+ <value>/user</value>
+ </property>
+
+ <property>
+ <name>mapreduce.jobhistory.intermediate-done-dir</name>
+ <value>/mapred/history/done_intermediate</value>
+ </property>
+
+ <property>
+ <name>mapreduce.jobhistory.done-dir</name>
+ <value>/mapred/history/done</value>
+ </property>
+
+ <property>
+ <name>mapreduce.shuffle.port</name>
+ <value>2233</value>
+ </property>
+
+ <property>
+ <!--TODO Look at what this property does. Apparently does not delay rampup-->
+ <name>yarn.app.mapreduce.am.job.reduce.rampup.limit</name>
+ <value>1.0</value>
+ </property>
+
+ <property>
+ <name>mapreduce.job.reduce.slowstart.completedmaps</name>
+ <value>1.0</value>
+ </property>
+
+ <property>
+ <name>yarn.app.mapreduce.am.log.level</name>
+ <value>DEBUG</value>
+ </property>
+
+ <!--property>
+ <name>mapreduce.map.log.level</name>
+ <value>DEBUG</value>
+ </property-->
+
+ <!--property>
+ <name>mapreduce.reduce.log.level</name>
+ <value>DEBUG</value>
+ </property-->
+
+</configuration>
Propchange: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/mapred-site.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/yarn-site.xml
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/sampleInput/yarn-site.xml?rev=1469642&view=auto
==============================================================================
--- incubator/tez/branches/TEZ-1/example_jobs/sampleInput/yarn-site.xml (added)
+++ incubator/tez/branches/TEZ-1/example_jobs/sampleInput/yarn-site.xml Thu Apr 18 23:54:18 2013
@@ -0,0 +1,79 @@
+<configuration>
+
+ <property>
+ <name>yarn.scheduler.minimum-allocation-mb</name>
+ <value>1024</value>
+ </property>
+
+ <property>
+ <name>yarn.scheduler.maximum-allocation-mb</name>
+ <value>6144</value>
+ </property>
+
+ <property>
+ <name>yarn.resourcemanager.scheduler.class</name>
+ <value>org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacityScheduler</value>
+ <!--value>org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo.FifoScheduler</value-->
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.local-dirs</name>
+ <value>/Users/sseth/work2/hortonworks/mrx/run/local/0</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.log-dirs</name>
+ <value>/Users/sseth/work2/hortonworks/mrx/run/logs</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.resource.memory-mb</name>
+ <value>4096</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.aux-services</name>
+ <value>mapreduce.shuffle</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.aux-service.mapreduce.shuffle.class</name>
+ <value>org.apache.hadoop.mapred.ShuffleHandler</value>
+ </property>
+
+ <property>
+ <name>yarn.log-aggregation-enable</name>
+ <value>false</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.log.retain-seconds</name>
+ <value>10800</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.remote-app-log-dir</name>
+ <value>/mapred/logs</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.remote-app-log-dir-suffix</name>
+ <value>logs</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.log-aggregation.compression-type</name>
+ <value>none</value>
+ </property>
+
+ <property>
+ <name>yarn.nodemanager.delete.debug-delay-sec</name>
+ <value>3600</value>
+ </property>
+
+ <property>
+ <name>mapreduce.shuffle.port</name>
+ <value>2233</value>
+ </property>
+
+</configuration>
Propchange: incubator/tez/branches/TEZ-1/example_jobs/sampleInput/yarn-site.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/appTokens
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/appTokens?rev=1469642&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/appTokens
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.jar
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.jar?rev=1469642&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.split
URL: http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/example_jobs/wc_mr_6m_1r/job.split?rev=1469642&view=auto
==============================================================================
Binary file - no diff available.