Path Lines of Code tez-api/src/main/java/org/apache/tez/common/ATSConstants.java 99 tez-api/src/main/java/org/apache/tez/common/Preconditions.java 77 tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java 340 tez-api/src/main/java/org/apache/tez/common/counters/TaskCounter.java 51 tez-api/src/main/java/org/apache/tez/common/security/JobTokenSecretManager.java 82 tez-api/src/main/java/org/apache/tez/common/security/TokenCache.java 117 tez-api/src/main/java/org/apache/tez/dag/api/EntityDescriptor.java 90 tez-api/src/main/java/org/apache/tez/dag/api/TezConfiguration.java 1094 tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java 90 tez-api/src/main/java/org/apache/tez/runtime/api/events/InputDataInformationEvent.java 69 tez-api/src/main/java/org/apache/tez/serviceplugins/api/ContainerLaunchRequest.java 45 tez-api/src/main/java/org/apache/tez/serviceplugins/api/ContainerLauncherContext.java 18 tez-api/src/main/java/org/apache/tez/serviceplugins/api/ContainerLauncherOperationBase.java 36 tez-api/src/main/java/org/apache/tez/serviceplugins/api/ServicePluginsDescriptor.java 84 tez-api/src/main/java/org/apache/tez/serviceplugins/api/TaskScheduler.java 66 tez-api/src/main/java/org/apache/tez/serviceplugins/api/TaskSchedulerContext.java 64 tez-common/src/main/java/org/apache/tez/common/TezUtilsInternal.java 325 tez-common/src/main/java/org/apache/tez/runtime/common/resources/InitialMemoryRequestContext.java 35 tez-dag/src/main/java/org/apache/tez/dag/api/client/DAGStatusBuilder.java 70 tez-dag/src/main/java/org/apache/tez/dag/app/ContainerContext.java 164 tez-dag/src/main/java/org/apache/tez/dag/app/ContainerHeartbeatHandler.java 31 tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java 2338 tez-dag/src/main/java/org/apache/tez/dag/app/RecoveryParser.java 961 tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorContextImpl.java 223 tez-dag/src/main/java/org/apache/tez/dag/app/TaskCommunicatorManager.java 552 tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java 393 tez-dag/src/main/java/org/apache/tez/dag/app/dag/RootInputInitializerManager.java 435 tez-dag/src/main/java/org/apache/tez/dag/app/dag/StateChangeNotifier.java 236 tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskAttempt.java 63 tez-dag/src/main/java/org/apache/tez/dag/app/dag/Vertex.java 151 tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventType.java 18 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java 2167 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGSchedulerNaturalOrderControlled.java 177 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/ImmediateStartVertexManager.java 106 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java 1580 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskImpl.java 1197 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java 96 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java 4168 tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java 569 tez-dag/src/main/java/org/apache/tez/dag/app/dag/speculation/legacy/LegacySpeculator.java 399 tez-dag/src/main/java/org/apache/tez/dag/app/dag/speculation/legacy/SimpleExponentialTaskRuntimeEstimator.java 126 tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherManager.java 254 tez-dag/src/main/java/org/apache/tez/dag/app/launcher/DeletionTrackerImpl.java 109 tez-dag/src/main/java/org/apache/tez/dag/app/launcher/LocalContainerLauncher.java 381 tez-dag/src/main/java/org/apache/tez/dag/app/launcher/TezContainerLauncherImpl.java 363 tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTALaunchRequest.java 62 tez-dag/src/main/java/org/apache/tez/dag/app/rm/ContainerAllocator.java 4 tez-dag/src/main/java/org/apache/tez/dag/app/rm/ContainerLauncherEventType.java 5 tez-dag/src/main/java/org/apache/tez/dag/app/rm/DagAwareYarnTaskScheduler.java 1694 tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerContextImpl.java 159 tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerManager.java 902 tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java 1870 tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventAssignTA.java 39 tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventStopFailed.java 12 tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventType.java 14 tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerImpl.java 1013 tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventTaskAttemptSucceeded.java 20 tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeImpl.java 424 tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/PerSourceNodeTracker.java 155 tez-dag/src/main/java/org/apache/tez/dag/app/web/AMWebController.java 711 tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java 212 tez-dag/src/main/java/org/apache/tez/dag/history/logging/impl/HistoryEventJsonConversion.java 659 tez-dag/src/main/java/org/apache/tez/dag/utils/TaskSpecificLaunchCmdOption.java 119 tez-dag/src/main/java/org/apache/tez/dag/utils/TezRuntimeChildJVM.java 59 tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicator.java 57 tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskCommunicatorContext.java 37 tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskHeartbeatRequest.java 40 tez-dag/src/main/java/org/apache/tez/serviceplugins/api/TaskHeartbeatResponse.java 27 tez-mapreduce/src/main/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReaderTez.java 121 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/ClientCache.java 23 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/ClientServiceDelegate.java 62 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/DAGJobStatus.java 302 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/ResourceMgrDelegate.java 180 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/YARNRunner.java 636 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/committer/MROutputCommitter.java 171 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/DeprecatedKeys.java 103 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/IDConverter.java 53 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/InputSplitInfo.java 25 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRHelpers.java 221 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRInputHelpers.java 572 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRJobConfig.java 342 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfigUtil.java 60 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/TezTypeConverters.java 44 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/MRCounters.java 270 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/MRReporter.java 56 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/TaskAttemptContextImpl.java 51 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/TaskAttemptContextImpl.java 81 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/MRTask.java 412 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/MRTaskReporter.java 88 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java 290 tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/reduce/ReduceProcessor.java 278 tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java 1376 tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/ATSFileParser.java 146 tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/datamodel/BaseInfo.java 66 tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/datamodel/DagInfo.java 452 tez-plugins/tez-protobuf-history-plugin/src/main/java/org/apache/tez/dag/history/logging/proto/HistoryEventProtoJsonConversion.java 559 tez-runtime-internals/src/main/java/org/apache/tez/common/ContainerContext.java 26 tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java 891 tez-runtime-internals/src/main/java/org/apache/tez/runtime/api/impl/InputSpec.java 51 tez-runtime-internals/src/main/java/org/apache/tez/runtime/api/impl/OutputSpec.java 48 tez-runtime-internals/src/main/java/org/apache/tez/runtime/api/impl/TaskSpec.java 227 tez-runtime-internals/src/main/java/org/apache/tez/runtime/api/impl/TezEvent.java 336 tez-runtime-internals/src/main/java/org/apache/tez/runtime/api/impl/TezTaskContextImpl.java 210 tez-runtime-internals/src/main/java/org/apache/tez/runtime/metrics/TaskCounterUpdater.java 81 tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezChild.java 457 tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner2.java 448 tez-runtime-library/findbugs-exclude.xml 188 tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/FairShuffleVertexManager.java 422 tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/InputReadyVertexManager.java 211 tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/ShuffleVertexManagerBase.java 618 tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java 157 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/api/Partitioner.java 9 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/api/TezRuntimeConfiguration.java 478 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/ConfigUtils.java 186 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/Constants.java 30 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/TezRuntimeUtils.java 225 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/ValuesIterator.java 149 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/readers/UnorderedKVReader.java 159 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/DiskFetchedInput.java 93 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/FetchedInput.java 91 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/Fetcher.java 951 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/ShuffleUtils.java 465 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleInputEventHandlerImpl.java 252 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleManager.java 966 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/SimpleFetchedInputAllocator.java 159 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/FetchedInputAllocatorOrderedGrouped.java 16 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/FetcherOrderedGrouped.java 640 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/InMemoryWriter.java 43 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/MergeManager.java 1061 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/Shuffle.java 338 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/ShuffleScheduler.java 1189 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/ExternalSorter.java 292 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFileInputStream.java 208 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFileOutputStream.java 72 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java 1186 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/TezMerger.java 822 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/dflt/DefaultSorter.java 1047 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/writers/BaseUnorderedPartitionedKVWriter.java 115 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/writers/UnorderedPartitionedKVWriter.java 1209 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/hadoop/compat/NullProgressable.java 11 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/OrderedGroupedKVInput.java 313 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/UnorderedKVInput.java 233 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/OrderedPartitionedKVOutput.java 210 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/UnorderedKVOutput.java 144 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/UnorderedPartitionedKVOutput.java 125 tez-runtime-library/src/main/java/org/apache/tez/runtime/library/resources/WeightedScalingMemoryDistributor.java 278 tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/SkewAnalyzer.java 189 tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/SlowTaskIdentifier.java 74 tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/SlowestVertexAnalyzer.java 145 tez-ui/src/main/webapp/app/models/abstract.js 33 tez-ui/src/main/webapp/app/serializers/loader.js 61