File tree Expand file tree Collapse file tree 5 files changed +8
-12
lines changed
hadoop-hdfs-project/hadoop-hdfs/src
main/java/org/apache/hadoop/hdfs
test/java/org/apache/hadoop/hdfs/server/namenode Expand file tree Collapse file tree 5 files changed +8
-12
lines changed Original file line number Diff line number Diff line change 2424import org .apache .hadoop .classification .InterfaceAudience ;
2525import org .apache .hadoop .fs .ReadOption ;
2626import org .apache .hadoop .hdfs .shortcircuit .ClientMmap ;
27+ import org .apache .hadoop .util .DataChecksum ;
2728
2829/**
2930 * An ExternalBlockReader uses pluggable ReplicaAccessor objects to read from
@@ -117,4 +118,9 @@ public ClientMmap getClientMmap(EnumSet<ReadOption> opts) {
117118 // For now, pluggable ReplicaAccessors do not support zero-copy.
118119 return null ;
119120 }
121+
122+ @ Override
123+ public DataChecksum getDataChecksum () {
124+ return null ;
125+ }
120126}
Original file line number Diff line number Diff line change @@ -84,7 +84,7 @@ ErasureCodingZone getErasureCodingZone(INodesInPath iip) throws IOException {
8484 new ArrayList <XAttr >(0 )
8585 : inode .getXAttrFeature ().getXAttrs ();
8686 for (XAttr xAttr : xAttrs ) {
87- if (XATTR_ERASURECODING_ZONE .equals (XAttrHelper .getPrefixName (xAttr ))) {
87+ if (XATTR_ERASURECODING_ZONE .equals (XAttrHelper .getPrefixedName (xAttr ))) {
8888 ByteArrayInputStream bIn =new ByteArrayInputStream (xAttr .getValue ());
8989 DataInputStream dIn =new DataInputStream (bIn );
9090 String ecPolicyName = WritableUtils .readString (dIn );
Original file line number Diff line number Diff line change @@ -258,12 +258,8 @@ public void blockIdCK(String blockId) {
258258 NumberReplicas numberReplicas = bm .countNodes (blockInfo );
259259 out .println ("Block Id: " + blockId );
260260 out .println ("Block belongs to: " +iNode .getFullPathName ());
261- <<<<<<< HEAD
262261 out .println ("No. of Expected Replica: " +
263- bm .getExpectedReplicaNum (bc , blockInfo ));
264- =======
265- out .println ("No. of Expected Replica: " + blockInfo .getReplication ());
266- >>>>>>> cbb249534aa72ff6c290c4f99766415aeea9d6f5
262+ bm .getExpectedReplicaNum (blockInfo ));
267263 out .println ("No. of live Replica: " + numberReplicas .liveReplicas ());
268264 out .println ("No. of excess Replica: " + numberReplicas .excessReplicas ());
269265 out .println ("No. of stale Replica: " +
Original file line number Diff line number Diff line change 2222
2323import org .apache .hadoop .hdfs .protocol .Block ;
2424import org .apache .hadoop .hdfs .server .blockmanagement .BlockInfo ;
25- <<<<<<< HEAD
2625import org .apache .hadoop .hdfs .server .blockmanagement .BlockInfoContiguous ;
27- =======
28- >>>>>>> cbb249534aa72ff6c290c4f99766415aeea9d6f5
2926import org .apache .hadoop .hdfs .server .common .HdfsServerConstants ;
3027import org .apache .hadoop .hdfs .server .namenode .INode ;
3128import org .apache .hadoop .hdfs .server .namenode .INode .BlocksMapUpdateInfo ;
Original file line number Diff line number Diff line change 5454import org .apache .hadoop .hdfs .protocol .HdfsConstants .SafeModeAction ;
5555import org .apache .hadoop .hdfs .protocol .LocatedBlock ;
5656import org .apache .hadoop .hdfs .protocol .LocatedBlocks ;
57- <<<<<<< HEAD
5857import org .apache .hadoop .hdfs .server .blockmanagement .BlockInfoContiguous ;
59- =======
60- >>>>>>> cbb249534aa72ff6c290c4f99766415aeea9d6f5
6158import org .apache .hadoop .hdfs .server .common .HdfsServerConstants ;
6259import org .apache .hadoop .hdfs .server .common .HdfsServerConstants .StartupOption ;
6360import org .apache .hadoop .security .UserGroupInformation ;
You can’t perform that action at this time.
0 commit comments