You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ab...@apache.org on 2022/02/10 10:05:56 UTC
[tez] branch master updated (6d7ef20 -> 7b66d3d)
This is an automated email from the ASF dual-hosted git repository.
abstractdog pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git.
from 6d7ef20 TEZ-4381: Speed up TestSecureShuffle (#180) (Mark Bathori reviewed by Laszlo Bodor)
add 7b66d3d TEZ-4227 Introduce convenient methods in TezID subclasses (#166) (Gergely Hanko reviewed by Laszlo Bodor)
No new revisions were added by this update.
Summary of changes:
.../records/{package-info.java => DAGIDAware.java} | 11 +-
.../{package-info.java => TaskAttemptIDAware.java} | 10 +-
.../{package-info.java => TaskIDAware.java} | 10 +-
.../apache/tez/dag/records/TezTaskAttemptID.java | 3 +-
.../java/org/apache/tez/dag/records/TezTaskID.java | 3 +-
.../org/apache/tez/dag/records/TezVertexID.java | 6 +-
.../{package-info.java => VertexIDAware.java} | 10 +-
.../tez/dag/records/VertexIdentifierImpl.java | 2 +-
.../org/apache/tez/dag/records/TestTezIds.java | 2 +-
.../java/org/apache/tez/dag/app/DAGAppMaster.java | 17 +-
.../org/apache/tez/dag/app/RecoveryParser.java | 12 +-
.../tez/dag/app/TaskCommunicatorManager.java | 6 +-
.../org/apache/tez/dag/app/dag/DAGScheduler.java | 8 +-
.../dag/app/dag/RootInputInitializerManager.java | 6 +-
.../main/java/org/apache/tez/dag/app/dag/Task.java | 5 +-
.../org/apache/tez/dag/app/dag/TaskAttempt.java | 11 +-
.../org/apache/tez/dag/app/dag/event/DAGEvent.java | 6 +-
.../dag/app/dag/event/DAGEventSchedulerUpdate.java | 13 +-
.../dag/app/dag/event/DAGEventVertexCompleted.java | 4 +-
.../dag/app/dag/event/DAGEventVertexReRunning.java | 2 +-
.../SpeculatorEventTaskAttemptStatusUpdate.java | 2 +-
.../tez/dag/app/dag/event/TaskAttemptEvent.java | 4 +-
.../apache/tez/dag/app/dag/event/TaskEvent.java | 4 +-
.../apache/tez/dag/app/dag/event/VertexEvent.java | 6 +-
.../dag/event/VertexEventTaskAttemptCompleted.java | 2 +-
.../org/apache/tez/dag/app/dag/impl/DAGImpl.java | 4 +-
.../dag/app/dag/impl/DAGSchedulerNaturalOrder.java | 6 +-
.../impl/DAGSchedulerNaturalOrderControlled.java | 15 +-
.../java/org/apache/tez/dag/app/dag/impl/Edge.java | 2 +-
.../tez/dag/app/dag/impl/TaskAttemptImpl.java | 62 ++---
.../org/apache/tez/dag/app/dag/impl/TaskImpl.java | 88 +++---
.../impl/TezRootInputInitializerContextImpl.java | 2 +-
.../apache/tez/dag/app/dag/impl/VertexImpl.java | 26 +-
.../apache/tez/dag/app/dag/impl/VertexManager.java | 6 +-
.../dag/speculation/legacy/LegacySpeculator.java | 8 +-
.../launcher/TaskAttemptFailedDeleteRunnable.java | 4 +-
.../tez/dag/app/rm/AMSchedulerEventTAEnded.java | 2 +-
.../tez/dag/app/rm/TaskSchedulerManager.java | 28 +-
.../container/AMContainerEventLaunchRequest.java | 2 +-
.../apache/tez/dag/app/web/AMWebController.java | 6 +-
.../apache/tez/dag/history/DAGHistoryEvent.java | 6 +-
.../tez/dag/history/HistoryEventHandler.java | 6 +-
.../tez/dag/history/events/DAGFinishedEvent.java | 6 +-
.../dag/history/events/DAGInitializedEvent.java | 6 +-
.../tez/dag/history/events/DAGStartedEvent.java | 6 +-
.../tez/dag/history/events/DAGSubmittedEvent.java | 6 +-
.../history/events/TaskAttemptFinishedEvent.java | 4 +-
.../history/events/TaskAttemptStartedEvent.java | 4 +-
.../tez/dag/history/events/TaskFinishedEvent.java | 4 +-
.../tez/dag/history/events/TaskStartedEvent.java | 4 +-
.../history/events/VertexCommitStartedEvent.java | 2 +-
.../events/VertexConfigurationDoneEvent.java | 4 +-
.../dag/history/events/VertexFinishedEvent.java | 6 +-
.../dag/history/events/VertexInitializedEvent.java | 6 +-
.../tez/dag/history/events/VertexStartedEvent.java | 6 +-
.../logging/impl/HistoryEventJsonConversion.java | 16 +-
.../tez/dag/history/recovery/RecoveryService.java | 12 +-
.../apache/tez/dag/app/TestMockDAGAppMaster.java | 12 +-
.../org/apache/tez/dag/app/TestSpeculation.java | 10 +-
.../apache/tez/dag/app/dag/impl/TestCommit.java | 136 +++++-----
.../apache/tez/dag/app/dag/impl/TestDAGImpl.java | 40 +--
.../tez/dag/app/dag/impl/TestDAGRecovery.java | 7 +-
.../tez/dag/app/dag/impl/TestDAGScheduler.java | 41 ++-
.../TestDAGSchedulerNaturalOrderControlled.java | 6 +-
.../org/apache/tez/dag/app/dag/impl/TestEdge.java | 6 +-
.../tez/dag/app/dag/impl/TestTaskAttempt.java | 73 ++---
.../apache/tez/dag/app/dag/impl/TestTaskImpl.java | 300 ++++++++++-----------
.../tez/dag/app/dag/impl/TestVertexImpl.java | 44 +--
.../apache/tez/dag/app/rm/TestContainerReuse.java | 12 +-
.../tez/dag/app/rm/TestTaskSchedulerManager.java | 6 +-
.../tez/dag/app/web/TestAMWebController.java | 14 +-
.../events/TestHistoryEventsProtoConversion.java | 20 +-
.../tez/service/impl/ContainerRunnerImpl.java | 4 +-
.../apache/tez/mapreduce/hadoop/IDConverter.java | 2 +-
.../hadoop/mapreduce/TaskAttemptContextImpl.java | 6 +-
.../org/apache/tez/mapreduce/processor/MRTask.java | 4 +-
.../tez/history/parser/SimpleHistoryParser.java | 12 +-
.../tez/history/parser/datamodel/BaseParser.java | 5 +-
.../logging/proto/HistoryEventProtoConverter.java | 16 +-
.../logging/proto/ProtoHistoryLoggingService.java | 12 +-
.../logging/ats/TimelineCachePluginImpl.java | 6 +-
.../history/ats/acls/TestATSHistoryWithACLs.java | 4 +-
.../logging/ats/ATSV15HistoryLoggingService.java | 12 +-
.../logging/ats/ATSHistoryLoggingService.java | 8 +-
.../ats/HistoryEventTimelineConversion.java | 81 +++---
.../apache/tez/runtime/api/impl/EventMetaData.java | 4 +-
.../org/apache/tez/runtime/api/impl/TaskSpec.java | 7 +-
.../tez/runtime/api/impl/TezTaskContextImpl.java | 7 +-
.../java/org/apache/tez/runtime/task/TezChild.java | 6 +-
.../test/RecoveryServiceWithEventHandlingHook.java | 16 +-
.../java/org/apache/tez/test/TestAMRecovery.java | 4 +-
91 files changed, 754 insertions(+), 719 deletions(-)
copy tez-common/src/main/java/org/apache/tez/dag/records/{package-info.java => DAGIDAware.java} (79%)
copy tez-common/src/main/java/org/apache/tez/dag/records/{package-info.java => TaskAttemptIDAware.java} (80%)
copy tez-common/src/main/java/org/apache/tez/dag/records/{package-info.java => TaskIDAware.java} (82%)
copy tez-common/src/main/java/org/apache/tez/dag/records/{package-info.java => VertexIDAware.java} (82%)