HDFS-4639. startFileInternal() should not increment generation stamp. Contributed by Plamen Jeliazkov.
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1467535 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
8acaea0028
commit
a59b953861
|
@ -149,6 +149,9 @@ Release 2.0.5-beta - UNRELEASED
|
|||
|
||||
HDFS-4643. Fix flakiness in TestQuorumJournalManager. (todd)
|
||||
|
||||
HDFS-4639. startFileInternal() should not increment generation stamp.
|
||||
(Plamen Jeliazkov via shv)
|
||||
|
||||
Release 2.0.4-alpha - UNRELEASED
|
||||
|
||||
INCOMPATIBLE CHANGES
|
||||
|
|
|
@ -230,8 +230,7 @@ public class FSDirectory implements Closeable {
|
|||
long preferredBlockSize,
|
||||
String clientName,
|
||||
String clientMachine,
|
||||
DatanodeDescriptor clientNode,
|
||||
long generationStamp)
|
||||
DatanodeDescriptor clientNode)
|
||||
throws FileAlreadyExistsException, QuotaExceededException,
|
||||
UnresolvedLinkException {
|
||||
waitForReady();
|
||||
|
|
|
@ -1853,9 +1853,8 @@ public class FSNamesystem implements Namesystem, FSClusterStats,
|
|||
checkFsObjectLimit();
|
||||
|
||||
// increment global generation stamp
|
||||
long genstamp = nextGenerationStamp();
|
||||
INodeFileUnderConstruction newNode = dir.addFile(src, permissions,
|
||||
replication, blockSize, holder, clientMachine, clientNode, genstamp);
|
||||
replication, blockSize, holder, clientMachine, clientNode);
|
||||
if (newNode == null) {
|
||||
throw new IOException("DIR* NameSystem.startFile: " +
|
||||
"Unable to add file to namespace.");
|
||||
|
|
|
@ -53,7 +53,7 @@ import com.google.common.base.Joiner;
|
|||
*/
|
||||
public class TestDFSUpgrade {
|
||||
|
||||
private static final int EXPECTED_TXID = 49;
|
||||
private static final int EXPECTED_TXID = 45;
|
||||
private static final Log LOG = LogFactory.getLog(TestDFSUpgrade.class.getName());
|
||||
private Configuration conf;
|
||||
private int testCounter = 0;
|
||||
|
|
|
@ -28,7 +28,6 @@ import static org.junit.Assert.assertTrue;
|
|||
import static org.junit.Assert.fail;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.FilenameFilter;
|
||||
import java.io.IOException;
|
||||
import java.lang.management.ManagementFactory;
|
||||
import java.net.InetSocketAddress;
|
||||
|
@ -1136,7 +1135,7 @@ public class TestCheckpoint {
|
|||
throw new IOException(e);
|
||||
}
|
||||
|
||||
final int EXPECTED_TXNS_FIRST_SEG = 12;
|
||||
final int EXPECTED_TXNS_FIRST_SEG = 11;
|
||||
|
||||
// the following steps should have happened:
|
||||
// edits_inprogress_1 -> edits_1-12 (finalized)
|
||||
|
|
Loading…
Reference in New Issue