HDFS-6942. Fix typos in log messages. Contributed by Ray Chiang.
This commit is contained in:
parent
4c17d4d975
commit
786b43c7a3
|
@ -423,7 +423,7 @@ class OpenFileCtx {
|
||||||
if (existantWriteCtx != null) {
|
if (existantWriteCtx != null) {
|
||||||
if (!existantWriteCtx.getReplied()) {
|
if (!existantWriteCtx.getReplied()) {
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("Repeated write request which hasn't be served: xid="
|
LOG.debug("Repeated write request which hasn't been served: xid="
|
||||||
+ xid + ", drop it.");
|
+ xid + ", drop it.");
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
@ -581,7 +581,7 @@ class OpenFileCtx {
|
||||||
* writing, and there is no other threads writing (i.e., asyncStatus is
|
* writing, and there is no other threads writing (i.e., asyncStatus is
|
||||||
* false), start the writing and set asyncStatus to true.
|
* false), start the writing and set asyncStatus to true.
|
||||||
*
|
*
|
||||||
* @return True if the new write is sequencial and we can start writing
|
* @return True if the new write is sequential and we can start writing
|
||||||
* (including the case that there is already a thread writing).
|
* (including the case that there is already a thread writing).
|
||||||
*/
|
*/
|
||||||
private synchronized boolean checkAndStartWrite(
|
private synchronized boolean checkAndStartWrite(
|
||||||
|
@ -906,7 +906,7 @@ class OpenFileCtx {
|
||||||
long offset = nextOffset.get();
|
long offset = nextOffset.get();
|
||||||
if (range.getMin() > offset) {
|
if (range.getMin() > offset) {
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("The next sequencial write has not arrived yet");
|
LOG.debug("The next sequential write has not arrived yet");
|
||||||
}
|
}
|
||||||
processCommits(nextOffset.get()); // handle race
|
processCommits(nextOffset.get()); // handle race
|
||||||
this.asyncStatus = false;
|
this.asyncStatus = false;
|
||||||
|
|
|
@ -1423,7 +1423,7 @@ public class RpcProgramNfs3 extends RpcProgram implements Nfs3Interface {
|
||||||
throw io;
|
throw io;
|
||||||
}
|
}
|
||||||
// This happens when startAfter was just deleted
|
// This happens when startAfter was just deleted
|
||||||
LOG.info("Cookie cound't be found: " + new String(startAfter)
|
LOG.info("Cookie couldn't be found: " + new String(startAfter)
|
||||||
+ ", do listing from beginning");
|
+ ", do listing from beginning");
|
||||||
dlisting = dfsClient
|
dlisting = dfsClient
|
||||||
.listPaths(dirFileIdPath, HdfsFileStatus.EMPTY_NAME);
|
.listPaths(dirFileIdPath, HdfsFileStatus.EMPTY_NAME);
|
||||||
|
|
|
@ -321,6 +321,8 @@ Release 2.6.0 - UNRELEASED
|
||||||
HDFS-6972. TestRefreshUserMappings.testRefreshSuperUserGroupsConfiguration
|
HDFS-6972. TestRefreshUserMappings.testRefreshSuperUserGroupsConfiguration
|
||||||
doesn't decode url correctly. (Yongjun Zhang via wang)
|
doesn't decode url correctly. (Yongjun Zhang via wang)
|
||||||
|
|
||||||
|
HDFS-6942. Fix typos in log messages. (Ray Chiang via wheat9)
|
||||||
|
|
||||||
BREAKDOWN OF HDFS-6134 AND HADOOP-10150 SUBTASKS AND RELATED JIRAS
|
BREAKDOWN OF HDFS-6134 AND HADOOP-10150 SUBTASKS AND RELATED JIRAS
|
||||||
|
|
||||||
HDFS-6387. HDFS CLI admin tool for creating & deleting an
|
HDFS-6387. HDFS CLI admin tool for creating & deleting an
|
||||||
|
|
|
@ -1752,7 +1752,7 @@ public class DataNode extends Configured
|
||||||
+ b + " (numBytes=" + b.getNumBytes() + ")"
|
+ b + " (numBytes=" + b.getNumBytes() + ")"
|
||||||
+ ", stage=" + stage
|
+ ", stage=" + stage
|
||||||
+ ", clientname=" + clientname
|
+ ", clientname=" + clientname
|
||||||
+ ", targests=" + Arrays.asList(targets));
|
+ ", targets=" + Arrays.asList(targets));
|
||||||
}
|
}
|
||||||
this.targets = targets;
|
this.targets = targets;
|
||||||
this.targetStorageTypes = targetStorageTypes;
|
this.targetStorageTypes = targetStorageTypes;
|
||||||
|
|
|
@ -125,7 +125,7 @@ public class TestFileAppend4 {
|
||||||
while (!recovered && tries-- > 0) {
|
while (!recovered && tries-- > 0) {
|
||||||
try {
|
try {
|
||||||
out = fs.append(file1);
|
out = fs.append(file1);
|
||||||
LOG.info("Successfully opened for appends");
|
LOG.info("Successfully opened for append");
|
||||||
recovered = true;
|
recovered = true;
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
LOG.info("Failed open for append, waiting on lease recovery");
|
LOG.info("Failed open for append, waiting on lease recovery");
|
||||||
|
|
|
@ -456,7 +456,7 @@ public class TestStartup {
|
||||||
checkNameSpace(conf);
|
checkNameSpace(conf);
|
||||||
|
|
||||||
// read an image compressed in Gzip and store it uncompressed
|
// read an image compressed in Gzip and store it uncompressed
|
||||||
LOG.info("Read an compressed iamge and store it as uncompressed.");
|
LOG.info("Read a compressed image and store it as uncompressed.");
|
||||||
conf.setBoolean(DFSConfigKeys.DFS_IMAGE_COMPRESS_KEY, false);
|
conf.setBoolean(DFSConfigKeys.DFS_IMAGE_COMPRESS_KEY, false);
|
||||||
checkNameSpace(conf);
|
checkNameSpace(conf);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue