Merge changes from trunk
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/db41a1b7 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/db41a1b7 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/db41a1b7 Branch: refs/heads/HDFS-6581 Commit: db41a1b7b944185e5e60a7fdf8cf43172b006a73 Parents: 4124905 6dae4b4 Author: Jing Zhao <ji...@apache.org> Authored: Tue Sep 9 22:47:50 2014 -0700 Committer: Jing Zhao <ji...@apache.org> Committed: Tue Sep 9 22:47:50 2014 -0700 ---------------------------------------------------------------------- hadoop-common-project/hadoop-common/CHANGES.txt | 9 +- .../hadoop/util/NativeLibraryChecker.java | 22 +- .../hadoop/util/TestNativeLibraryChecker.java | 29 +++ hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt | 16 +- .../hadoop/hdfs/server/balancer/Balancer.java | 8 +- .../server/blockmanagement/BlockManager.java | 21 +- .../server/blockmanagement/DatanodeManager.java | 6 +- .../server/blockmanagement/HostFileManager.java | 4 - .../hdfs/server/datanode/BPOfferService.java | 9 +- .../hdfs/server/datanode/BPServiceActor.java | 2 +- .../server/datanode/BlockPoolSliceStorage.java | 120 +++++++++-- .../hdfs/server/datanode/DataStorage.java | 31 ++- .../server/datanode/fsdataset/FsDatasetSpi.java | 11 + .../datanode/fsdataset/impl/FsDatasetImpl.java | 10 + .../server/namenode/EncryptionZoneManager.java | 12 ++ .../hdfs/server/namenode/FSDirectory.java | 2 +- .../server/namenode/FSImageFormatPBINode.java | 18 +- .../hdfs/server/namenode/FSNamesystem.java | 46 ++--- .../server/namenode/NameNodeLayoutVersion.java | 5 +- .../hadoop-hdfs/src/main/proto/fsimage.proto | 8 +- .../org/apache/hadoop/hdfs/DFSTestUtil.java | 37 ++++ .../apache/hadoop/hdfs/TestEncryptionZones.java | 8 + .../hdfs/server/balancer/TestBalancer.java | 5 +- .../server/datanode/SimulatedFSDataset.java | 8 + .../datanode/TestDataNodeRollingUpgrade.java | 205 ++++++++++++++++--- .../hdfs/server/namenode/FSXAttrBaseTest.java | 75 ++++--- .../hdfs/server/namenode/NameNodeAdapter.java | 2 +- .../hadoop-hdfs/src/test/resources/editsStored | Bin 4992 -> 4999 bytes .../src/test/resources/editsStored.xml | 138 ++++++------- .../yarn/sls/appmaster/MRAMSimulator.java | 43 ++-- hadoop-yarn-project/CHANGES.txt | 6 + 31 files changed, 673 insertions(+), 243 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Balancer.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java ---------------------------------------------------------------------- diff --cc hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java index 9b030e7,8470680..956900d --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java @@@ -398,27 -394,7 +397,11 @@@ public class BlockManager lifetimeMin*60*1000L, 0, null, encryptionAlgorithm); } } - + + public BlockStoragePolicy getStoragePolicy(final String policyName) { + return storagePolicySuite.getPolicy(policyName); + } + - public long getReplicationRecheckInterval() { - return replicationRecheckInterval; - } - - public AtomicLong excessBlocksCount() { - return excessBlocksCount; - } - - public void clearInvalidateBlocks() { - invalidateBlocks.clear(); - } - - void setReplicationMonitor(Runnable replicationMonitor) { - replicationThread = new Daemon(replicationMonitor); - } - public void setBlockPoolId(String blockPoolId) { if (isBlockTokenEnabled()) { blockTokenSecretManager.setBlockPoolId(blockPoolId); http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirectory.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSImageFormatPBINode.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeLayoutVersion.java ---------------------------------------------------------------------- diff --cc hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeLayoutVersion.java index c2896cf,404e205..512913b --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeLayoutVersion.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeLayoutVersion.java @@@ -67,8 -67,8 +67,9 @@@ public class NameNodeLayoutVersion EDITLOG_LENGTH(-56, "Add length field to every edit log op"), XATTRS(-57, "Extended attributes"), CREATE_OVERWRITE(-58, "Use single editlog record for " + - "creating file with overwrite"), - BLOCK_STORAGE_POLICY(-59, "Block Storage policy"); + "creating file with overwrite"), - XATTRS_NAMESPACE_EXT(-59, "Increase number of xattr namespaces"); ++ XATTRS_NAMESPACE_EXT(-59, "Increase number of xattr namespaces"), ++ BLOCK_STORAGE_POLICY(-60, "Block Storage policy"); private final FeatureInfo info; http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/main/proto/fsimage.proto ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/DFSTestUtil.java ---------------------------------------------------------------------- diff --cc hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/DFSTestUtil.java index a1aa7d6,e3a265f..e8a2484 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/DFSTestUtil.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/DFSTestUtil.java @@@ -1458,54 -1405,37 +1461,88 @@@ public class DFSTestUtil return expectedPrimary.getDatanodeDescriptor(); } + public static void toolRun(Tool tool, String cmd, int retcode, String contain) + throws Exception { + String [] cmds = StringUtils.split(cmd, ' '); + System.out.flush(); + System.err.flush(); + PrintStream origOut = System.out; + PrintStream origErr = System.err; + String output = null; + int ret = 0; + try { + ByteArrayOutputStream bs = new ByteArrayOutputStream(1024); + PrintStream out = new PrintStream(bs); + System.setOut(out); + System.setErr(out); + ret = tool.run(cmds); + System.out.flush(); + System.err.flush(); + out.close(); + output = bs.toString(); + } finally { + System.setOut(origOut); + System.setErr(origErr); + } + System.out.println("Output for command: " + cmd + " retcode: " + ret); + if (output != null) { + System.out.println(output); + } + assertEquals(retcode, ret); + if (contain != null) { + assertTrue("The real output is: " + output + ".\n It should contain: " + + contain, output.contains(contain)); + } + } + + public static void FsShellRun(String cmd, int retcode, String contain, + Configuration conf) throws Exception { + FsShell shell = new FsShell(new Configuration(conf)); + toolRun(shell, cmd, retcode, contain); + } + + public static void DFSAdminRun(String cmd, int retcode, String contain, + Configuration conf) throws Exception { + DFSAdmin admin = new DFSAdmin(new Configuration(conf)); + toolRun(admin, cmd, retcode, contain); + } + + public static void FsShellRun(String cmd, Configuration conf) + throws Exception { + FsShellRun(cmd, 0, null, conf); + } ++ + public static void addDataNodeLayoutVersion(final int lv, final String description) + throws NoSuchFieldException, IllegalAccessException { + Preconditions.checkState(lv < DataNodeLayoutVersion.CURRENT_LAYOUT_VERSION); + + // Override {@link DataNodeLayoutVersion#CURRENT_LAYOUT_VERSION} via reflection. + Field modifiersField = Field.class.getDeclaredField("modifiers"); + modifiersField.setAccessible(true); + Field field = DataNodeLayoutVersion.class.getField("CURRENT_LAYOUT_VERSION"); + field.setAccessible(true); + modifiersField.setInt(field, field.getModifiers() & ~Modifier.FINAL); + field.setInt(null, lv); + + // Override {@link HdfsConstants#DATANODE_LAYOUT_VERSION} + field = HdfsConstants.class.getField("DATANODE_LAYOUT_VERSION"); + field.setAccessible(true); + modifiersField.setInt(field, field.getModifiers() & ~Modifier.FINAL); + field.setInt(null, lv); + + // Inject the feature into the FEATURES map. + final LayoutVersion.FeatureInfo featureInfo = + new LayoutVersion.FeatureInfo(lv, lv + 1, description, false); + final LayoutVersion.LayoutFeature feature = + new LayoutVersion.LayoutFeature() { + @Override + public LayoutVersion.FeatureInfo getInfo() { + return featureInfo; + } + }; + + // Update the FEATURES map with the new layout version. + LayoutVersion.updateMap(DataNodeLayoutVersion.FEATURES, + new LayoutVersion.LayoutFeature[] { feature }); + } } http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/test/resources/editsStored ---------------------------------------------------------------------- diff --cc hadoop-hdfs-project/hadoop-hdfs/src/test/resources/editsStored index 3b66d43,754f690..ecfbb9f Binary files differ http://git-wip-us.apache.org/repos/asf/hadoop/blob/db41a1b7/hadoop-hdfs-project/hadoop-hdfs/src/test/resources/editsStored.xml ---------------------------------------------------------------------- diff --cc hadoop-hdfs-project/hadoop-hdfs/src/test/resources/editsStored.xml index c8eecc3,7cfb689..8cafa9f --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/resources/editsStored.xml +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/resources/editsStored.xml @@@ -1,6 -1,6 +1,6 @@@ <?xml version="1.0" encoding="UTF-8"?> <EDITS> -- <EDITS_VERSION>-59</EDITS_VERSION> ++ <EDITS_VERSION>-60</EDITS_VERSION> <RECORD> <OPCODE>OP_START_LOG_SEGMENT</OPCODE> <DATA> @@@ -13,8 -13,8 +13,8 @@@ <TXID>2</TXID> <DELEGATION_KEY> <KEY_ID>1</KEY_ID> - <EXPIRY_DATE>1410634509611</EXPIRY_DATE> - <KEY>201e2572e03d089c</KEY> - <EXPIRY_DATE>1403590428625</EXPIRY_DATE> - <KEY>16f34bfba67b2552</KEY> ++ <EXPIRY_DATE>1410915997709</EXPIRY_DATE> ++ <KEY>309e81e09dc6c75a</KEY> </DELEGATION_KEY> </DATA> </RECORD> @@@ -24,8 -24,8 +24,8 @@@ <TXID>3</TXID> <DELEGATION_KEY> <KEY_ID>2</KEY_ID> - <EXPIRY_DATE>1410634509614</EXPIRY_DATE> - <KEY>ef4542e27fb38301</KEY> - <EXPIRY_DATE>1403590428631</EXPIRY_DATE> - <KEY>dbe6282854469833</KEY> ++ <EXPIRY_DATE>1410915997711</EXPIRY_DATE> ++ <KEY>8a2399843e754bee</KEY> </DELEGATION_KEY> </DATA> </RECORD> @@@ -37,19 -37,19 +37,19 @@@ <INODEID>16386</INODEID> <PATH>/file_create</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310217</MTIME> - <ATIME>1409943310217</ATIME> - <MTIME>1402899229669</MTIME> - <ATIME>1402899229669</ATIME> ++ <MTIME>1410224798292</MTIME> ++ <ATIME>1410224798292</ATIME> <BLOCKSIZE>512</BLOCKSIZE> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_588677218_1</CLIENT_NAME> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_1233039831_1</CLIENT_NAME> ++ <CLIENT_NAME>DFSClient_NONMAPREDUCE_1374813776_1</CLIENT_NAME> <CLIENT_MACHINE>127.0.0.1</CLIENT_MACHINE> - <OVERWRITE>false</OVERWRITE> + <OVERWRITE>true</OVERWRITE> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>420</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>8</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>5</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -60,8 -60,8 +60,8 @@@ <INODEID>0</INODEID> <PATH>/file_create</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310240</MTIME> - <ATIME>1409943310217</ATIME> - <MTIME>1402899229711</MTIME> - <ATIME>1402899229669</ATIME> ++ <MTIME>1410224798315</MTIME> ++ <ATIME>1410224798292</ATIME> <BLOCKSIZE>512</BLOCKSIZE> <CLIENT_NAME></CLIENT_NAME> <CLIENT_MACHINE></CLIENT_MACHINE> @@@ -88,20 -80,20 +88,20 @@@ <LENGTH>0</LENGTH> <SRC>/file_create</SRC> <DST>/file_moved</DST> - <TIMESTAMP>1409943310247</TIMESTAMP> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <TIMESTAMP>1402899229718</TIMESTAMP> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>10</RPC_CALLID> ++ <TIMESTAMP>1410224798322</TIMESTAMP> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>8</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_DELETE</OPCODE> <DATA> - <TXID>7</TXID> + <TXID>8</TXID> <LENGTH>0</LENGTH> <PATH>/file_moved</PATH> - <TIMESTAMP>1409943310253</TIMESTAMP> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <TIMESTAMP>1402899229730</TIMESTAMP> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>11</RPC_CALLID> ++ <TIMESTAMP>1410224798328</TIMESTAMP> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>9</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -111,9 -103,9 +111,9 @@@ <LENGTH>0</LENGTH> <INODEID>16387</INODEID> <PATH>/directory_mkdir</PATH> - <TIMESTAMP>1409943310260</TIMESTAMP> - <TIMESTAMP>1402899229748</TIMESTAMP> ++ <TIMESTAMP>1410224798335</TIMESTAMP> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>493</MODE> </PERMISSION_STATUS> @@@ -143,11 -135,11 +143,11 @@@ <RECORD> <OPCODE>OP_CREATE_SNAPSHOT</OPCODE> <DATA> - <TXID>12</TXID> + <TXID>13</TXID> <SNAPSHOTROOT>/directory_mkdir</SNAPSHOTROOT> <SNAPSHOTNAME>snapshot1</SNAPSHOTNAME> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>16</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>14</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -157,18 -149,18 +157,18 @@@ <SNAPSHOTROOT>/directory_mkdir</SNAPSHOTROOT> <SNAPSHOTOLDNAME>snapshot1</SNAPSHOTOLDNAME> <SNAPSHOTNEWNAME>snapshot2</SNAPSHOTNEWNAME> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>17</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>15</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_DELETE_SNAPSHOT</OPCODE> <DATA> - <TXID>14</TXID> + <TXID>15</TXID> <SNAPSHOTROOT>/directory_mkdir</SNAPSHOTROOT> <SNAPSHOTNAME>snapshot2</SNAPSHOTNAME> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>18</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>16</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -179,10 -194,31 +179,10 @@@ <INODEID>16388</INODEID> <PATH>/file_create</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310284</MTIME> - <ATIME>1409943310284</ATIME> - <MTIME>1402899229912</MTIME> - <ATIME>1402899229912</ATIME> ++ <MTIME>1410224798359</MTIME> ++ <ATIME>1410224798359</ATIME> <BLOCKSIZE>512</BLOCKSIZE> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_588677218_1</CLIENT_NAME> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_1233039831_1</CLIENT_NAME> ++ <CLIENT_NAME>DFSClient_NONMAPREDUCE_1374813776_1</CLIENT_NAME> <CLIENT_MACHINE>127.0.0.1</CLIENT_MACHINE> <OVERWRITE>true</OVERWRITE> <PERMISSION_STATUS> @@@ -190,8 -226,8 +190,8 @@@ <GROUPNAME>supergroup</GROUPNAME> <MODE>420</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>21</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>17</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -202,8 -238,8 +202,8 @@@ <INODEID>0</INODEID> <PATH>/file_create</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310286</MTIME> - <ATIME>1409943310284</ATIME> - <MTIME>1402899229931</MTIME> - <ATIME>1402899229912</ATIME> ++ <MTIME>1410224798361</MTIME> ++ <ATIME>1410224798359</ATIME> <BLOCKSIZE>512</BLOCKSIZE> <CLIENT_NAME></CLIENT_NAME> <CLIENT_MACHINE></CLIENT_MACHINE> @@@ -265,10 -301,10 +265,10 @@@ <LENGTH>0</LENGTH> <SRC>/file_create</SRC> <DST>/file_moved</DST> - <TIMESTAMP>1409943310302</TIMESTAMP> - <TIMESTAMP>1402899229963</TIMESTAMP> ++ <TIMESTAMP>1410224798379</TIMESTAMP> <OPTIONS>NONE</OPTIONS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>26</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>24</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -279,19 -315,19 +279,19 @@@ <INODEID>16389</INODEID> <PATH>/file_concat_target</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310306</MTIME> - <ATIME>1409943310306</ATIME> - <MTIME>1402899229981</MTIME> - <ATIME>1402899229981</ATIME> ++ <MTIME>1410224798382</MTIME> ++ <ATIME>1410224798382</ATIME> <BLOCKSIZE>512</BLOCKSIZE> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_588677218_1</CLIENT_NAME> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_1233039831_1</CLIENT_NAME> ++ <CLIENT_NAME>DFSClient_NONMAPREDUCE_1374813776_1</CLIENT_NAME> <CLIENT_MACHINE>127.0.0.1</CLIENT_MACHINE> - <OVERWRITE>false</OVERWRITE> + <OVERWRITE>true</OVERWRITE> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>420</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>28</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>26</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -396,8 -432,8 +396,8 @@@ <INODEID>0</INODEID> <PATH>/file_concat_target</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310402</MTIME> - <ATIME>1409943310306</ATIME> - <MTIME>1402899230219</MTIME> - <ATIME>1402899229981</ATIME> ++ <MTIME>1410224798476</MTIME> ++ <ATIME>1410224798382</ATIME> <BLOCKSIZE>512</BLOCKSIZE> <CLIENT_NAME></CLIENT_NAME> <CLIENT_MACHINE></CLIENT_MACHINE> @@@ -432,19 -468,19 +432,19 @@@ <INODEID>16390</INODEID> <PATH>/file_concat_0</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310407</MTIME> - <ATIME>1409943310407</ATIME> - <MTIME>1402899230235</MTIME> - <ATIME>1402899230235</ATIME> ++ <MTIME>1410224798479</MTIME> ++ <ATIME>1410224798479</ATIME> <BLOCKSIZE>512</BLOCKSIZE> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_588677218_1</CLIENT_NAME> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_1233039831_1</CLIENT_NAME> ++ <CLIENT_NAME>DFSClient_NONMAPREDUCE_1374813776_1</CLIENT_NAME> <CLIENT_MACHINE>127.0.0.1</CLIENT_MACHINE> - <OVERWRITE>false</OVERWRITE> + <OVERWRITE>true</OVERWRITE> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>420</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>41</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>39</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -549,8 -585,8 +549,8 @@@ <INODEID>0</INODEID> <PATH>/file_concat_0</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310430</MTIME> - <ATIME>1409943310407</ATIME> - <MTIME>1402899230307</MTIME> - <ATIME>1402899230235</ATIME> ++ <MTIME>1410224798501</MTIME> ++ <ATIME>1410224798479</ATIME> <BLOCKSIZE>512</BLOCKSIZE> <CLIENT_NAME></CLIENT_NAME> <CLIENT_MACHINE></CLIENT_MACHINE> @@@ -585,19 -621,19 +585,19 @@@ <INODEID>16391</INODEID> <PATH>/file_concat_1</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310434</MTIME> - <ATIME>1409943310434</ATIME> - <MTIME>1402899230320</MTIME> - <ATIME>1402899230320</ATIME> ++ <MTIME>1410224798504</MTIME> ++ <ATIME>1410224798504</ATIME> <BLOCKSIZE>512</BLOCKSIZE> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_588677218_1</CLIENT_NAME> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_1233039831_1</CLIENT_NAME> ++ <CLIENT_NAME>DFSClient_NONMAPREDUCE_1374813776_1</CLIENT_NAME> <CLIENT_MACHINE>127.0.0.1</CLIENT_MACHINE> - <OVERWRITE>false</OVERWRITE> + <OVERWRITE>true</OVERWRITE> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>420</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>53</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>51</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -702,8 -738,8 +702,8 @@@ <INODEID>0</INODEID> <PATH>/file_concat_1</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310457</MTIME> - <ATIME>1409943310434</ATIME> - <MTIME>1402899230383</MTIME> - <ATIME>1402899230320</ATIME> ++ <MTIME>1410224798530</MTIME> ++ <ATIME>1410224798504</ATIME> <BLOCKSIZE>512</BLOCKSIZE> <CLIENT_NAME></CLIENT_NAME> <CLIENT_MACHINE></CLIENT_MACHINE> @@@ -733,16 -769,16 +733,16 @@@ <RECORD> <OPCODE>OP_CONCAT_DELETE</OPCODE> <DATA> - <TXID>58</TXID> + <TXID>57</TXID> <LENGTH>0</LENGTH> <TRG>/file_concat_target</TRG> - <TIMESTAMP>1409943310460</TIMESTAMP> - <TIMESTAMP>1402899230394</TIMESTAMP> ++ <TIMESTAMP>1410224798533</TIMESTAMP> <SOURCES> <SOURCE1>/file_concat_0</SOURCE1> <SOURCE2>/file_concat_1</SOURCE2> </SOURCES> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>64</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>62</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -753,15 -789,15 +753,15 @@@ <INODEID>16392</INODEID> <PATH>/file_symlink</PATH> <VALUE>/file_concat_target</VALUE> - <MTIME>1409943310463</MTIME> - <ATIME>1409943310463</ATIME> - <MTIME>1402899230406</MTIME> - <ATIME>1402899230406</ATIME> ++ <MTIME>1410224798537</MTIME> ++ <ATIME>1410224798537</ATIME> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>511</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>65</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>63</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -772,19 -808,19 +772,19 @@@ <INODEID>16393</INODEID> <PATH>/hard-lease-recovery-test</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943310466</MTIME> - <ATIME>1409943310466</ATIME> - <MTIME>1402899230413</MTIME> - <ATIME>1402899230413</ATIME> ++ <MTIME>1410224798540</MTIME> ++ <ATIME>1410224798540</ATIME> <BLOCKSIZE>512</BLOCKSIZE> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_588677218_1</CLIENT_NAME> - <CLIENT_NAME>DFSClient_NONMAPREDUCE_1233039831_1</CLIENT_NAME> ++ <CLIENT_NAME>DFSClient_NONMAPREDUCE_1374813776_1</CLIENT_NAME> <CLIENT_MACHINE>127.0.0.1</CLIENT_MACHINE> - <OVERWRITE>false</OVERWRITE> + <OVERWRITE>true</OVERWRITE> <PERMISSION_STATUS> - <USERNAME>andrew</USERNAME> + <USERNAME>jing</USERNAME> <GROUPNAME>supergroup</GROUPNAME> <MODE>420</MODE> </PERMISSION_STATUS> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>66</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>64</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -839,8 -875,8 +839,8 @@@ <RECORD> <OPCODE>OP_REASSIGN_LEASE</OPCODE> <DATA> - <TXID>66</TXID> - <LEASEHOLDER>DFSClient_NONMAPREDUCE_1233039831_1</LEASEHOLDER> + <TXID>65</TXID> - <LEASEHOLDER>DFSClient_NONMAPREDUCE_588677218_1</LEASEHOLDER> ++ <LEASEHOLDER>DFSClient_NONMAPREDUCE_1374813776_1</LEASEHOLDER> <PATH>/hard-lease-recovery-test</PATH> <NEWHOLDER>HDFS_NameNode</NEWHOLDER> </DATA> @@@ -853,8 -889,8 +853,8 @@@ <INODEID>0</INODEID> <PATH>/hard-lease-recovery-test</PATH> <REPLICATION>1</REPLICATION> - <MTIME>1409943313176</MTIME> - <ATIME>1409943310466</ATIME> - <MTIME>1402899232526</MTIME> - <ATIME>1402899230413</ATIME> ++ <MTIME>1410224801265</MTIME> ++ <ATIME>1410224798540</ATIME> <BLOCKSIZE>512</BLOCKSIZE> <CLIENT_NAME></CLIENT_NAME> <CLIENT_MACHINE></CLIENT_MACHINE> @@@ -881,18 -917,18 +881,18 @@@ <MODE>493</MODE> <LIMIT>9223372036854775807</LIMIT> <MAXRELATIVEEXPIRY>2305843009213693951</MAXRELATIVEEXPIRY> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>73</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>71</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_MODIFY_CACHE_POOL</OPCODE> <DATA> - <TXID>69</TXID> + <TXID>68</TXID> <POOLNAME>pool1</POOLNAME> <LIMIT>99</LIMIT> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>74</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>72</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -903,37 -939,37 +903,37 @@@ <PATH>/path</PATH> <REPLICATION>1</REPLICATION> <POOL>pool1</POOL> - <EXPIRATION>2305844419157007447</EXPIRATION> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <EXPIRATION>2305844412112927450</EXPIRATION> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>75</RPC_CALLID> ++ <EXPIRATION>2305844419438495525</EXPIRATION> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>73</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_MODIFY_CACHE_DIRECTIVE</OPCODE> <DATA> - <TXID>71</TXID> + <TXID>70</TXID> <ID>1</ID> <REPLICATION>2</REPLICATION> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>76</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>74</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_REMOVE_CACHE_DIRECTIVE</OPCODE> <DATA> - <TXID>72</TXID> + <TXID>71</TXID> <ID>1</ID> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>77</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>75</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_REMOVE_CACHE_POOL</OPCODE> <DATA> - <TXID>73</TXID> + <TXID>72</TXID> <POOLNAME>pool1</POOLNAME> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>78</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>76</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -979,8 -1015,8 +979,8 @@@ <NAME>a1</NAME> <VALUE>0x313233</VALUE> </XATTR> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>80</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>78</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -993,8 -1029,8 +993,8 @@@ <NAME>a2</NAME> <VALUE>0x373839</VALUE> </XATTR> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>81</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>79</RPC_CALLID> </DATA> </RECORD> <RECORD> @@@ -1006,22 -1042,22 +1006,22 @@@ <NAMESPACE>USER</NAMESPACE> <NAME>a2</NAME> </XATTR> - <RPC_CLIENTID>e33c0cc9-12b1-49a2-80eb-4d35d3b79960</RPC_CLIENTID> - <RPC_CLIENTID>e03f4a52-3d85-4e05-8942-286185e639bd</RPC_CLIENTID> - <RPC_CALLID>82</RPC_CALLID> ++ <RPC_CLIENTID>b53e8d0a-8d92-4067-b8c8-637ac951bac2</RPC_CLIENTID> + <RPC_CALLID>80</RPC_CALLID> </DATA> </RECORD> <RECORD> <OPCODE>OP_ROLLING_UPGRADE_START</OPCODE> <DATA> - <TXID>78</TXID> - <STARTTIME>1402899233646</STARTTIME> + <TXID>77</TXID> - <STARTTIME>1409943313537</STARTTIME> ++ <STARTTIME>1410224801616</STARTTIME> </DATA> </RECORD> <RECORD> <OPCODE>OP_ROLLING_UPGRADE_FINALIZE</OPCODE> <DATA> - <TXID>79</TXID> - <FINALIZETIME>1402899233647</FINALIZETIME> + <TXID>78</TXID> - <FINALIZETIME>1409943313537</FINALIZETIME> ++ <FINALIZETIME>1410224801616</FINALIZETIME> </DATA> </RECORD> <RECORD>