testLogAggregationServiceWithPatterns() |  | 0% | | n/a | 1 | 1 | 96 | 96 | 1 | 1 |
testMultipleAppsLogAggregation() |  | 0% | | n/a | 1 | 1 | 74 | 74 | 1 | 1 |
verifyContainerLogs(LogAggregationService, ApplicationId, ContainerId[], int, int, String[], int, boolean, String[]) |  | 0% |  | 0% | 16 | 16 | 93 | 93 | 1 | 1 |
testLogAggregationService(boolean) |  | 0% |  | 0% | 7 | 7 | 76 | 76 | 1 | 1 |
verifyLocalFileDeletion(LogAggregationService) |  | 0% |  | 0% | 4 | 4 | 55 | 55 | 1 | 1 |
testAppLogDirCreation() |  | 0% | | n/a | 1 | 1 | 56 | 56 | 1 | 1 |
testLogAggregationCreateDirsFailsWithoutKillingNM() |  | 0% | | n/a | 1 | 1 | 52 | 52 | 1 | 1 |
testLogAggregationServiceWithPatternsAndIntervals() |  | 0% | | n/a | 1 | 1 | 46 | 46 | 1 | 1 |
testVerifyAndCreateRemoteDirsFailure() |  | 0% | | n/a | 1 | 1 | 36 | 36 | 1 | 1 |
setupAndTestSampleContainerPolicy(int, float, int, boolean) |  | 0% |  | 0% | 10 | 10 | 35 | 35 | 1 | 1 |
testLogAggregationForRealContainerLaunch() |  | 0% | | n/a | 1 | 1 | 46 | 46 | 1 | 1 |
testFailedDirsLocalFileDeletionAfterUpload() |  | 0% |  | 0% | 2 | 2 | 35 | 35 | 1 | 1 |
checkEvents(EventHandler, Event[], boolean, String[]) |  | 0% |  | 0% | 8 | 8 | 39 | 39 | 1 | 1 |
testLogAggregationInitAppFailsWithoutKillingNM() |  | 0% | | n/a | 1 | 1 | 30 | 30 | 1 | 1 |
testNoLogsUploadedOnAppFinish() |  | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
testAddNewTokenSentFromRMForLogAggregation() |  | 0% | | n/a | 1 | 1 | 27 | 27 | 1 | 1 |
testNoContainerOnNode() |  | 0% | | n/a | 1 | 1 | 25 | 25 | 1 | 1 |
testFixedSizeThreadPool() |  | 0% |  | 0% | 2 | 2 | 26 | 26 | 1 | 1 |
testRemoveExpiredDelegationTokensBeforeUpload() |  | 0% | | n/a | 1 | 1 | 24 | 24 | 1 | 1 |
testVerifyAndCreateRemoteDirNonExistence() |  | 0% |  | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
testRemoteRootLogDirIsCreatedWithCorrectGroupOwner() |  | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
verifySkipUnnecessaryNNOperations(LogAggregationContext, int, int, int) |  | 0% | | n/a | 1 | 1 | 25 | 25 | 1 | 1 |
numOfLogsAvailable(LogAggregationService, ApplicationId, boolean, String) |  | 0% |  | 0% | 7 | 7 | 28 | 28 | 1 | 1 |
writeContainerLogs(File, ContainerId, String[], String[]) |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
testInvalidThreadPoolSizeValue(String) |  | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
testLocalFileDeletionOnDiskFull() |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
testLimitSizeContainerLogAggregationPolicy() |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
testAMOrFailedContainerPolicy() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
testFailedOrKilledContainerPolicy() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
testStopAfterError() |  | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
testLogAggregatorCleanup() |  | 0% |  | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
testFailedContainerPolicy() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
testAMOnlyContainerPolicy() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
verifyDefaultPolicy(ApplicationId, LogAggregationService) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
eventToString(Event, String[]) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
createLogAggregationService(ApplicationId, String, String, boolean) |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
createContainer(ApplicationAttemptId, long, ContainerType) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
testLocalFileRemainsAfterUploadOnCleanupDisable() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
finishApplication(ApplicationId, LogAggregationService) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
testLocalFileDeletionAfterUpload() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
testNoneContainerPolicy() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
createApplication() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
finishContainer(ApplicationId, LogAggregationService, ContainerType, long, int, String[]) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
waitAndCheckLogNum(LogAggregationService, ApplicationId, int, int, boolean, String) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
testRollingMonitorIntervalGreaterThanSet() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
testRollingMonitorIntervalLessThanSet() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
tearDown() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
finishContainers(ApplicationId, LogAggregationService, long, int, int, String[]) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
verifyLogAggFinishEvent(ApplicationId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
mockExpiredToken() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
verifyAcls(Map) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
setup() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
TestLogAggregationService() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
testLogAggregationAbsentContainer() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
testSkipUnnecessaryNNOperationsForService() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
testRollingMonitorIntervalDefault() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
mockRenewableToken() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$testRemoveExpiredDelegationTokensBeforeUpload$1(UserGroupInformation, Token) |  | 0% |  | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
createAppAcls() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
testInvalidPolicyClassName() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
testNullPolicyClassName() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
testDefaultPolicyWithoutLogAggregationContext() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
testSkipUnnecessaryNNOperationsForShortJob() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
verifyContainerLogs(LogAggregationService, ApplicationId, ContainerId[], String[], int, boolean, String[]) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
mockApplication() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createDispatcher() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createLogAggregationService(ApplicationId, Class, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$verifyLocalFileDeletion$0(File) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
testSampleContainerPolicyWithSmallApp() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testSampleContainerPolicyWithLargeApp() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testSampleContainerPolicyWithZeroSampleRate() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testSampleContainerPolicyWith100PercentSampleRate() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testSampleContainerPolicyWithZeroMinThreshold() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testSampleContainerPolicyWithCustomizedSettings() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testClusterSampleContainerPolicy() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testDefaultClusterSampleContainerPolicy() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testInvalidThreadPoolSizeNaN() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testInvalidThreadPoolSizeNegative() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testInvalidThreadPoolSizeXLarge() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testLogAggregationServiceWithInterval() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
testLogAggregationServiceWithRetention() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |