YARN-2777. Mark the end of individual log in aggregated log. Contributed
by Varun Saxena
This commit is contained in:
parent
15612313f5
commit
1a4b528691
@ -411,6 +411,9 @@ Release 2.7.0 - UNRELEASED
|
|||||||
YARN-2854. Updated the documentation of the timeline service and the generic
|
YARN-2854. Updated the documentation of the timeline service and the generic
|
||||||
history service. (Naganarasimha G R via zjshen)
|
history service. (Naganarasimha G R via zjshen)
|
||||||
|
|
||||||
|
YARN-2777. Mark the end of individual log in aggregated log.
|
||||||
|
(Varun Saxena via xgong)
|
||||||
|
|
||||||
OPTIMIZATIONS
|
OPTIMIZATIONS
|
||||||
|
|
||||||
YARN-2990. FairScheduler's delay-scheduling always waits for node-local and
|
YARN-2990. FairScheduler's delay-scheduling always waits for node-local and
|
||||||
|
@ -711,6 +711,7 @@ private static void readContainerLogs(DataInputStream valueStream,
|
|||||||
pendingRead > buf.length ? buf.length : (int) pendingRead;
|
pendingRead > buf.length ? buf.length : (int) pendingRead;
|
||||||
len = valueStream.read(buf, 0, toRead);
|
len = valueStream.read(buf, 0, toRead);
|
||||||
}
|
}
|
||||||
|
out.println("End of LogType:" + fileType);
|
||||||
out.println("");
|
out.println("");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -257,7 +257,8 @@ private void testReadAcontainerLog(boolean logUploadedTime) throws Exception {
|
|||||||
+ (logUploadedTime ? ("\nLog Upload Time:" + Times.format(System
|
+ (logUploadedTime ? ("\nLog Upload Time:" + Times.format(System
|
||||||
.currentTimeMillis())).length() : 0)
|
.currentTimeMillis())).length() : 0)
|
||||||
+ ("\nLogLength:" + numChars).length()
|
+ ("\nLogLength:" + numChars).length()
|
||||||
+ "\nLog Contents:\n".length() + numChars + "\n".length();
|
+ "\nLog Contents:\n".length() + numChars + "\n".length()
|
||||||
|
+ "End of LogType:stdout\n".length();
|
||||||
Assert.assertTrue("LogType not matched", s.contains("LogType:stdout"));
|
Assert.assertTrue("LogType not matched", s.contains("LogType:stdout"));
|
||||||
Assert.assertTrue("log file:stderr should not be aggregated.", !s.contains("LogType:stderr"));
|
Assert.assertTrue("log file:stderr should not be aggregated.", !s.contains("LogType:stderr"));
|
||||||
Assert.assertTrue("log file:logs should not be aggregated.", !s.contains("LogType:logs"));
|
Assert.assertTrue("log file:logs should not be aggregated.", !s.contains("LogType:logs"));
|
||||||
|
Loading…
Reference in New Issue
Block a user