You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hdfs-commits@hadoop.apache.org by el...@apache.org on 2010/11/18 22:23:30 UTC
svn commit: r1036639 - in /hadoop/hdfs/branches/branch-0.22: ./
src/c++/libhdfs/ src/contrib/hdfsproxy/ src/java/
src/java/org/apache/hadoop/hdfs/protocol/
src/java/org/apache/hadoop/hdfs/server/common/
src/java/org/apache/hadoop/hdfs/server/datanode/ ...
Author: eli
Date: Thu Nov 18 21:23:29 2010
New Revision: 1036639
URL: http://svn.apache.org/viewvc?rev=1036639&view=rev
Log:
HDFS-259. svn merge -c 1036213 from trunk
Modified:
hadoop/hdfs/branches/branch-0.22/ (props changed)
hadoop/hdfs/branches/branch-0.22/CHANGES.txt
hadoop/hdfs/branches/branch-0.22/build.xml (props changed)
hadoop/hdfs/branches/branch-0.22/src/c++/libhdfs/ (props changed)
hadoop/hdfs/branches/branch-0.22/src/contrib/hdfsproxy/ (props changed)
hadoop/hdfs/branches/branch-0.22/src/java/ (props changed)
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/protocol/FSConstants.java
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/common/Storage.java
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/ReplicaInfo.java (props changed)
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/BackupStorage.java
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/FSImage.java
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/SecondaryNameNode.java
hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/ImageLoaderCurrent.java
hadoop/hdfs/branches/branch-0.22/src/test/hdfs/ (props changed)
hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/TestDFSUpgradeFromImage.java
hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/UpgradeUtilities.java
hadoop/hdfs/branches/branch-0.22/src/webapps/datanode/ (props changed)
hadoop/hdfs/branches/branch-0.22/src/webapps/hdfs/ (props changed)
hadoop/hdfs/branches/branch-0.22/src/webapps/secondary/ (props changed)
Propchange: hadoop/hdfs/branches/branch-0.22/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -1,3 +1,4 @@
/hadoop/core/branches/branch-0.19/hdfs:713112
/hadoop/hdfs/branches/HDFS-265:796829-820463
/hadoop/hdfs/branches/branch-0.21:820487
+/hadoop/hdfs/trunk:1036213
Modified: hadoop/hdfs/branches/branch-0.22/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/CHANGES.txt?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/CHANGES.txt (original)
+++ hadoop/hdfs/branches/branch-0.22/CHANGES.txt Thu Nov 18 21:23:29 2010
@@ -213,6 +213,9 @@ Release 0.22.0 - Unreleased
HDFS-1483. DFSClient.getBlockLocations should indicate if corresponding
blocks are corrupt. (Patrick Kling via hairong)
+ HDFS-259. Remove intentionally corrupt 0.13 directory layout creation.
+ (Todd Lipcon via eli).
+
OPTIMIZATIONS
HDFS-1140. Speedup INode.getPathComponents. (Dmytro Molkov via shv)
Propchange: hadoop/hdfs/branches/branch-0.22/build.xml
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/build.xml:779102
/hadoop/hdfs/branches/HDFS-265/build.xml:796829-820463
/hadoop/hdfs/branches/branch-0.21/build.xml:820487
+/hadoop/hdfs/trunk/build.xml:1036213
Propchange: hadoop/hdfs/branches/branch-0.22/src/c++/libhdfs/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -1,2 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/c++/libhdfs:713112
/hadoop/core/trunk/src/c++/libhdfs:776175-784663
+/hadoop/hdfs/trunk/src/c++/libhdfs:1036213
Propchange: hadoop/hdfs/branches/branch-0.22/src/contrib/hdfsproxy/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/src/contrib/hdfsproxy:776175-784663
/hadoop/hdfs/branches/HDFS-265/src/contrib/hdfsproxy:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/contrib/hdfsproxy:820487
+/hadoop/hdfs/trunk/src/contrib/hdfsproxy:1036213
Propchange: hadoop/hdfs/branches/branch-0.22/src/java/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/src/hdfs:776175-785643,785929-786278
/hadoop/hdfs/branches/HDFS-265/src/java:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/java:820487
+/hadoop/hdfs/trunk/src/java:1036213
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/protocol/FSConstants.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/protocol/FSConstants.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/protocol/FSConstants.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/protocol/FSConstants.java Thu Nov 18 21:23:29 2010
@@ -91,7 +91,7 @@ public interface FSConstants {
// Version is reflected in the data storage file.
// Versions are negative.
// Decrement LAYOUT_VERSION to define a new version.
- public static final int LAYOUT_VERSION = -26;
+ public static final int LAYOUT_VERSION = -27;
// Current version:
- // -26: support image checksum.
+ // -27: remove intentionally corrupt pre-0.13 image directory
}
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/common/Storage.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/common/Storage.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/common/Storage.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/common/Storage.java Thu Nov 18 21:23:29 2010
@@ -64,7 +64,7 @@ public abstract class Storage extends St
// Constants
- // last layout version that did not suppot upgrades
+ // last layout version that did not support upgrades
protected static final int LAST_PRE_UPGRADE_LAYOUT_VERSION = -3;
// this corresponds to Hadoop-0.14.
@@ -80,7 +80,7 @@ public abstract class Storage extends St
private static final String STORAGE_FILE_LOCK = "in_use.lock";
protected static final String STORAGE_FILE_VERSION = "VERSION";
- public static final String STORAGE_DIR_CURRENT = "current";
+ public static final String STORAGE_DIR_CURRENT = "current";
private static final String STORAGE_DIR_PREVIOUS = "previous";
private static final String STORAGE_TMP_REMOVED = "removed.tmp";
private static final String STORAGE_TMP_PREVIOUS = "previous.tmp";
@@ -256,7 +256,6 @@ public abstract class Storage extends St
* @throws IOException
*/
public void write() throws IOException {
- corruptPreUpgradeStorage(root);
write(getVersionFile());
}
@@ -472,8 +471,7 @@ public abstract class Storage extends St
if (startOpt == HdfsConstants.StartupOption.FORMAT)
return StorageState.NOT_FORMATTED;
if (startOpt != HdfsConstants.StartupOption.IMPORT) {
- //make sure no conversion is required
- checkConversionNeeded(this);
+ checkOldLayoutStorage(this);
}
// check whether current directory is valid
@@ -686,16 +684,22 @@ public abstract class Storage extends St
protected void addStorageDir(StorageDirectory sd) {
storageDirs.add(sd);
}
-
- public abstract boolean isConversionNeeded(StorageDirectory sd) throws IOException;
- /*
- * Coversion is no longer supported. So this should throw exception if
- * conversion is needed.
- */
- private void checkConversionNeeded(StorageDirectory sd) throws IOException {
- if (isConversionNeeded(sd)) {
- //throw an exception
+ /**
+ * Return true if the layout of the given storage directory is from a version
+ * of Hadoop prior to the introduction of the "current" and "previous"
+ * directories which allow upgrade and rollback.
+ */
+ public abstract boolean isPreUpgradableLayout(StorageDirectory sd)
+ throws IOException;
+
+ /**
+ * Check if the given storage directory comes from a version of Hadoop
+ * prior to when the directory layout changed (ie 0.13). If this is
+ * the case, this method throws an IOException.
+ */
+ private void checkOldLayoutStorage(StorageDirectory sd) throws IOException {
+ if (isPreUpgradableLayout(sd)) {
checkVersionUpgradable(0);
}
}
@@ -851,20 +855,4 @@ public abstract class Storage extends St
+ "-" + Integer.toString(storage.getLayoutVersion())
+ "-" + Long.toString(storage.getCTime());
}
-
- // Pre-upgrade version compatibility
- protected abstract void corruptPreUpgradeStorage(File rootDir) throws IOException;
-
- protected void writeCorruptedData(RandomAccessFile file) throws IOException {
- final String messageForPreUpgradeVersion =
- "\nThis file is INTENTIONALLY CORRUPTED so that versions\n"
- + "of Hadoop prior to 0.13 (which are incompatible\n"
- + "with this directory layout) will fail to start.\n";
-
- file.seek(0);
- file.writeInt(FSConstants.LAYOUT_VERSION);
- org.apache.hadoop.hdfs.DeprecatedUTF8.writeString(file, "");
- file.writeBytes(messageForPreUpgradeVersion);
- file.getFD().sync();
- }
}
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/DataStorage.java Thu Nov 18 21:23:29 2010
@@ -190,7 +190,8 @@ public class DataStorage extends Storage
storageID = ssid;
}
- public boolean isConversionNeeded(StorageDirectory sd) throws IOException {
+ @Override
+ public boolean isPreUpgradableLayout(StorageDirectory sd) throws IOException {
File oldF = new File(sd.getRoot(), "storage");
if (!oldF.exists())
return false;
@@ -462,22 +463,6 @@ public class DataStorage extends Storage
new File(to, blockNames[i]), oldLV);
}
- protected void corruptPreUpgradeStorage(File rootDir) throws IOException {
- File oldF = new File(rootDir, "storage");
- if (oldF.exists())
- return;
- // recreate old storage file to let pre-upgrade versions fail
- if (!oldF.createNewFile())
- throw new IOException("Cannot create file " + oldF);
- RandomAccessFile oldFile = new RandomAccessFile(oldF, "rws");
- // write new version into old storage file
- try {
- writeCorruptedData(oldFile);
- } finally {
- oldFile.close();
- }
- }
-
private void verifyDistributedUpgradeProgress(
NamespaceInfo nsInfo
) throws IOException {
Propchange: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/datanode/ReplicaInfo.java
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -4,3 +4,4 @@
/hadoop/core/trunk/src/hdfs/org/apache/hadoop/hdfs/server/datanode/ReplicaInfo.java:776175-785643,785929-786278
/hadoop/hdfs/branches/HDFS-265/src/java/org/apache/hadoop/hdfs/server/datanode/ReplicaInfo.java:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/java/org/apache/hadoop/hdfs/server/datanode/ReplicaInfo.java:820487
+/hadoop/hdfs/trunk/src/java/org/apache/hadoop/hdfs/server/datanode/ReplicaInfo.java:1036213
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/BackupStorage.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/BackupStorage.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/BackupStorage.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/BackupStorage.java Thu Nov 18 21:23:29 2010
@@ -61,7 +61,7 @@ public class BackupStorage extends FSIma
}
@Override
- public boolean isConversionNeeded(StorageDirectory sd) {
+ public boolean isPreUpgradableLayout(StorageDirectory sd) throws IOException {
return false;
}
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/FSImage.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/FSImage.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/FSImage.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/FSImage.java Thu Nov 18 21:23:29 2010
@@ -900,12 +900,9 @@ public class FSImage extends Storage {
return editLog;
}
- public boolean isConversionNeeded(StorageDirectory sd) throws IOException {
+ public boolean isPreUpgradableLayout(StorageDirectory sd) throws IOException {
File oldImageDir = new File(sd.getRoot(), "image");
if (!oldImageDir.exists()) {
- if(sd.getVersionFile().exists())
- throw new InconsistentFSStateException(sd.getRoot(),
- oldImageDir + " does not exist.");
return false;
}
// check the layout version inside the image file
@@ -921,7 +918,7 @@ public class FSImage extends Storage {
}
return true;
}
-
+
//
// Atomic move sequence, to recover from interrupted checkpoint
//
@@ -2214,25 +2211,6 @@ public class FSImage extends Storage {
}
}
- protected void corruptPreUpgradeStorage(File rootDir) throws IOException {
- File oldImageDir = new File(rootDir, "image");
- if (!oldImageDir.exists())
- if (!oldImageDir.mkdir())
- throw new IOException("Cannot create directory " + oldImageDir);
- File oldImage = new File(oldImageDir, "fsimage");
- if (!oldImage.exists())
- // recreate old image file to let pre-upgrade versions fail
- if (!oldImage.createNewFile())
- throw new IOException("Cannot create file " + oldImage);
- RandomAccessFile oldFile = new RandomAccessFile(oldImage, "rws");
- // write new version into old image file
- try {
- writeCorruptedData(oldFile);
- } finally {
- oldFile.close();
- }
- }
-
private boolean getDistributedUpgradeState() {
FSNamesystem ns = getFSNamesystem();
return ns == null ? false : ns.getDistributedUpgradeState();
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/SecondaryNameNode.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/SecondaryNameNode.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/SecondaryNameNode.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/server/namenode/SecondaryNameNode.java Thu Nov 18 21:23:29 2010
@@ -587,12 +587,6 @@ public class SecondaryNameNode implement
super(conf);
}
- @Override
- public
- boolean isConversionNeeded(StorageDirectory sd) {
- return false;
- }
-
/**
* Analyze checkpoint directories.
* Create directories if they do not exist.
Modified: hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/ImageLoaderCurrent.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/ImageLoaderCurrent.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/ImageLoaderCurrent.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/ImageLoaderCurrent.java Thu Nov 18 21:23:29 2010
@@ -120,7 +120,7 @@ class ImageLoaderCurrent implements Imag
protected final DateFormat dateFormat =
new SimpleDateFormat("yyyy-MM-dd HH:mm");
private static int [] versions =
- {-16, -17, -18, -19, -20, -21, -22, -23, -24, -25, -26};
+ {-16, -17, -18, -19, -20, -21, -22, -23, -24, -25, -26, -27};
private int imageVersion = 0;
/* (non-Javadoc)
Propchange: hadoop/hdfs/branches/branch-0.22/src/test/hdfs/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/src/test/hdfs:776175-785643
/hadoop/hdfs/branches/HDFS-265/src/test/hdfs:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/test/hdfs:820487
+/hadoop/hdfs/trunk/src/test/hdfs:1036213
Modified: hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/TestDFSUpgradeFromImage.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/TestDFSUpgradeFromImage.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/TestDFSUpgradeFromImage.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/TestDFSUpgradeFromImage.java Thu Nov 18 21:23:29 2010
@@ -32,6 +32,7 @@ import org.apache.hadoop.fs.FileUtil;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.protocol.FSConstants;
import org.apache.hadoop.hdfs.server.common.HdfsConstants.StartupOption;
+import org.apache.hadoop.util.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -48,6 +49,8 @@ public class TestDFSUpgradeFromImage ext
private static final Log LOG = LogFactory.getLog(
"org.apache.hadoop.hdfs.TestDFSUpgradeFromImage");
+ private static File TEST_ROOT_DIR =
+ new File(MiniDFSCluster.getBaseDirectory());
public int numDataNodes = 4;
@@ -203,4 +206,47 @@ public class TestDFSUpgradeFromImage ext
if (cluster != null) { cluster.shutdown(); }
}
}
+
+ /**
+ * Test that sets up a fake image from Hadoop 0.3.0 and tries to start a
+ * NN, verifying that the correct error message is thrown.
+ */
+ public void testFailOnPreUpgradeImage() throws IOException {
+ Configuration conf = new HdfsConfiguration();
+
+ File namenodeStorage = new File(TEST_ROOT_DIR, "nnimage-0.3.0");
+ conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, namenodeStorage.toString());
+
+ // Set up a fake NN storage that looks like an ancient Hadoop dir circa 0.3.0
+ FileUtil.fullyDelete(namenodeStorage);
+ assertTrue("Make " + namenodeStorage, namenodeStorage.mkdirs());
+ File imageDir = new File(namenodeStorage, "image");
+ assertTrue("Make " + imageDir, imageDir.mkdirs());
+
+ // Hex dump of a formatted image from Hadoop 0.3.0
+ File imageFile = new File(imageDir, "fsimage");
+ byte[] imageBytes = StringUtils.hexStringToByte(
+ "fffffffee17c0d2700000000");
+ FileOutputStream fos = new FileOutputStream(imageFile);
+ try {
+ fos.write(imageBytes);
+ } finally {
+ fos.close();
+ }
+
+ // Now try to start an NN from it
+
+ try {
+ new MiniDFSCluster.Builder(conf).numDataNodes(0)
+ .format(false)
+ .manageDataDfsDirs(false)
+ .manageNameDfsDirs(false)
+ .startupOption(StartupOption.REGULAR)
+ .build();
+ fail("Was able to start NN from 0.3.0 image");
+ } catch (IOException ioe) {
+ LOG.info("Got expected exception", ioe);
+ assertTrue(ioe.toString().contains("Old layout version is 'too old'"));
+ }
+ }
}
Modified: hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/UpgradeUtilities.java
URL: http://svn.apache.org/viewvc/hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/UpgradeUtilities.java?rev=1036639&r1=1036638&r2=1036639&view=diff
==============================================================================
--- hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/UpgradeUtilities.java (original)
+++ hadoop/hdfs/branches/branch-0.22/src/test/hdfs/org/apache/hadoop/hdfs/UpgradeUtilities.java Thu Nov 18 21:23:29 2010
@@ -279,23 +279,11 @@ public class UpgradeUtilities {
localFS.copyToLocalFile(new Path(namenodeStorage.toString(), "current"),
new Path(newDir.toString()),
false);
- Path newImgDir = new Path(newDir.getParent(), "image");
- if (!localFS.exists(newImgDir))
- localFS.copyToLocalFile(
- new Path(namenodeStorage.toString(), "image"),
- newImgDir,
- false);
break;
case DATA_NODE:
localFS.copyToLocalFile(new Path(datanodeStorage.toString(), "current"),
new Path(newDir.toString()),
false);
- Path newStorageFile = new Path(newDir.getParent(), "storage");
- if (!localFS.exists(newStorageFile))
- localFS.copyToLocalFile(
- new Path(datanodeStorage.toString(), "storage"),
- newStorageFile,
- false);
break;
}
retVal[i] = newDir;
Propchange: hadoop/hdfs/branches/branch-0.22/src/webapps/datanode/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/src/webapps/datanode:776175-784663
/hadoop/hdfs/branches/HDFS-265/src/webapps/datanode:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/webapps/datanode:820487
+/hadoop/hdfs/trunk/src/webapps/datanode:1036213
Propchange: hadoop/hdfs/branches/branch-0.22/src/webapps/hdfs/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/src/webapps/hdfs:776175-784663
/hadoop/hdfs/branches/HDFS-265/src/webapps/hdfs:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/webapps/hdfs:820487
+/hadoop/hdfs/trunk/src/webapps/hdfs:1036213
Propchange: hadoop/hdfs/branches/branch-0.22/src/webapps/secondary/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 18 21:23:29 2010
@@ -2,3 +2,4 @@
/hadoop/core/trunk/src/webapps/secondary:776175-784663
/hadoop/hdfs/branches/HDFS-265/src/webapps/secondary:796829-820463
/hadoop/hdfs/branches/branch-0.21/src/webapps/secondary:820487
+/hadoop/hdfs/trunk/src/webapps/secondary:1036213