Skip to content

Commit 2a50694

Browse files
hfutatzhanghbhfutatzhanghb
committed
fix checkstyle.
1 parent 7043379 commit 2a50694

File tree

6 files changed

+79
-97
lines changed

6 files changed

+79
-97
lines changed

‎hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/protocolPB/AsyncRpcProtocolPBUtil.java‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818

1919
package org.apache.hadoop.hdfs.protocolPB;
2020

21-
import org.apache.hadoop.hdfs.server.federation.router.RouterRpcServer;
2221
import org.apache.hadoop.hdfs.server.federation.router.ThreadLocalContext;
2322
import org.apache.hadoop.hdfs.server.federation.router.async.ApplyFunction;
2423
import org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil;

‎hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/protocolPB/RouterClientNamenodeProtocolServerSideTranslatorPB.java‎

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@
3535
import org.apache.hadoop.hdfs.protocol.HdfsPartialListing;
3636
import org.apache.hadoop.hdfs.protocol.LocatedBlock;
3737
import org.apache.hadoop.hdfs.protocol.OpenFilesIterator;
38-
import org.apache.hadoop.hdfs.protocol.proto.AclProtos;
3938
import org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusRequestProto;
4039
import org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto;
4140
import org.apache.hadoop.hdfs.protocol.proto.AclProtos.ModifyAclEntriesRequestProto;
@@ -215,7 +214,6 @@
215214
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdatePipelineResponseProto;
216215
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpgradeStatusRequestProto;
217216
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpgradeStatusResponseProto;
218-
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos;
219217
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.CreateEncryptionZoneRequestProto;
220218
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.CreateEncryptionZoneResponseProto;
221219
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.GetEZForPathRequestProto;
@@ -226,7 +224,6 @@
226224
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ListReencryptionStatusResponseProto;
227225
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ReencryptEncryptionZoneRequestProto;
228226
import org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ReencryptEncryptionZoneResponseProto;
229-
import org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos;
230227
import org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos.AddErasureCodingPoliciesRequestProto;
231228
import org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos.AddErasureCodingPoliciesResponseProto;
232229
import org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos.DisableErasureCodingPolicyRequestProto;
@@ -248,7 +245,6 @@
248245
import org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos.UnsetErasureCodingPolicyRequestProto;
249246
import org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos.UnsetErasureCodingPolicyResponseProto;
250247
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos;
251-
import org.apache.hadoop.hdfs.protocol.proto.XAttrProtos;
252248
import org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsRequestProto;
253249
import org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto;
254250
import org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsRequestProto;
@@ -261,7 +257,6 @@
261257
import org.apache.hadoop.io.EnumSetWritable;
262258
import org.apache.hadoop.io.Text;
263259
import org.apache.hadoop.ipc.RemoteException;
264-
import org.apache.hadoop.security.proto.SecurityProtos;
265260
import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto;
266261
import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto;
267262
import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto;
@@ -543,7 +538,8 @@ public TruncateResponseProto truncate(
543538
RpcController controller,
544539
TruncateRequestProto req) {
545540
asyncRouterServer(() -> server.truncate(req.getSrc(), req.getNewLength(),
546-
req.getClientName()), result -> TruncateResponseProto.newBuilder().setResult(result).build());
541+
req.getClientName()),
542+
result -> TruncateResponseProto.newBuilder().setResult(result).build());
547543
return null;
548544
}
549545

@@ -1195,8 +1191,7 @@ public ModifyCacheDirectiveResponseProto modifyCacheDirective(
11951191
}
11961192

11971193
@Override
1198-
public RemoveCacheDirectiveResponseProto
1199-
removeCacheDirective(
1194+
public RemoveCacheDirectiveResponseProto removeCacheDirective(
12001195
RpcController controller,
12011196
RemoveCacheDirectiveRequestProto request) {
12021197
asyncRouterServer(() -> {

‎hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/protocolPB/RouterNamenodeProtocolServerSideTranslatorPB.java‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,10 +18,8 @@
1818
package org.apache.hadoop.hdfs.protocolPB;
1919

2020
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
21-
import org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos;
2221
import org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionRequestProto;
2322
import org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionResponseProto;
24-
import org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos;
2523
import org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointRequestProto;
2624
import org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointResponseProto;
2725
import org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportRequestProto;
@@ -56,8 +54,6 @@
5654
import org.apache.hadoop.thirdparty.protobuf.RpcController;
5755
import org.apache.hadoop.thirdparty.protobuf.ServiceException;
5856

59-
import java.io.IOException;
60-
6157
import static org.apache.hadoop.hdfs.protocolPB.AsyncRpcProtocolPBUtil.asyncRouterServer;
6258

6359
public class RouterNamenodeProtocolServerSideTranslatorPB

‎hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/protocolPB/RouterRefreshUserMappingsProtocolServerSideTranslatorPB.java‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,7 @@ public RefreshUserToGroupsMappingsResponseProto refreshUserToGroupsMappings(
6767
}
6868

6969
@Override
70-
public RefreshSuperUserGroupsConfigurationResponseProto
71-
refreshSuperUserGroupsConfiguration(
70+
public RefreshSuperUserGroupsConfigurationResponseProto refreshSuperUserGroupsConfiguration(
7271
RpcController controller,
7372
RefreshSuperUserGroupsConfigurationRequestProto request) throws ServiceException {
7473
if (!isAsyncRpc) {

‎hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/ClientNamenodeProtocolServerSideTranslatorPB.java‎

Lines changed: 72 additions & 79 deletions
Original file line numberDiff line numberDiff line change
@@ -341,29 +341,29 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
341341
VOID_UNSET_STORAGE_POLICY_RESPONSE =
342342
UnsetStoragePolicyResponseProto.newBuilder().build();
343343

344-
protected static final CreateResponseProto VOID_CREATE_RESPONSE =
345-
CreateResponseProto.newBuilder().build();
344+
protected static final CreateResponseProto VOID_CREATE_RESPONSE =
345+
CreateResponseProto.newBuilder().build();
346346

347-
protected static final SetPermissionResponseProto VOID_SET_PERM_RESPONSE =
348-
SetPermissionResponseProto.newBuilder().build();
347+
protected static final SetPermissionResponseProto VOID_SET_PERM_RESPONSE =
348+
SetPermissionResponseProto.newBuilder().build();
349349

350-
protected static final SetOwnerResponseProto VOID_SET_OWNER_RESPONSE =
351-
SetOwnerResponseProto.newBuilder().build();
350+
protected static final SetOwnerResponseProto VOID_SET_OWNER_RESPONSE =
351+
SetOwnerResponseProto.newBuilder().build();
352352

353-
protected static final AbandonBlockResponseProto VOID_ADD_BLOCK_RESPONSE =
354-
AbandonBlockResponseProto.newBuilder().build();
353+
protected static final AbandonBlockResponseProto VOID_ADD_BLOCK_RESPONSE =
354+
AbandonBlockResponseProto.newBuilder().build();
355355

356-
protected static final ReportBadBlocksResponseProto VOID_REP_BAD_BLOCK_RESPONSE =
357-
ReportBadBlocksResponseProto.newBuilder().build();
356+
protected static final ReportBadBlocksResponseProto VOID_REP_BAD_BLOCK_RESPONSE =
357+
ReportBadBlocksResponseProto.newBuilder().build();
358358

359-
protected static final ConcatResponseProto VOID_CONCAT_RESPONSE =
360-
ConcatResponseProto.newBuilder().build();
359+
protected static final ConcatResponseProto VOID_CONCAT_RESPONSE =
360+
ConcatResponseProto.newBuilder().build();
361361

362-
protected static final Rename2ResponseProto VOID_RENAME2_RESPONSE =
363-
Rename2ResponseProto.newBuilder().build();
362+
protected static final Rename2ResponseProto VOID_RENAME2_RESPONSE =
363+
Rename2ResponseProto.newBuilder().build();
364364

365-
protected static final GetListingResponseProto VOID_GETLISTING_RESPONSE =
366-
GetListingResponseProto.newBuilder().build();
365+
protected static final GetListingResponseProto VOID_GETLISTING_RESPONSE =
366+
GetListingResponseProto.newBuilder().build();
367367

368368
protected static final GetBatchedListingResponseProto
369369
VOID_GETBATCHEDLISTING_RESPONSE =
@@ -372,86 +372,78 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
372372
.setHasMore(false)
373373
.build();
374374

375-
protected static final RenewLeaseResponseProto VOID_RENEWLEASE_RESPONSE =
376-
RenewLeaseResponseProto.newBuilder().build();
375+
protected static final RenewLeaseResponseProto VOID_RENEWLEASE_RESPONSE =
376+
RenewLeaseResponseProto.newBuilder().build();
377377

378378
protected static final RefreshNodesResponseProto VOID_REFRESHNODES_RESPONSE =
379-
RefreshNodesResponseProto.newBuilder().build();
379+
RefreshNodesResponseProto.newBuilder().build();
380380

381-
protected static final FinalizeUpgradeResponseProto VOID_FINALIZEUPGRADE_RESPONSE =
382-
FinalizeUpgradeResponseProto.newBuilder().build();
381+
protected static final FinalizeUpgradeResponseProto VOID_FINALIZEUPGRADE_RESPONSE =
382+
FinalizeUpgradeResponseProto.newBuilder().build();
383383

384-
protected static final MetaSaveResponseProto VOID_METASAVE_RESPONSE =
385-
MetaSaveResponseProto.newBuilder().build();
384+
protected static final MetaSaveResponseProto VOID_METASAVE_RESPONSE =
385+
MetaSaveResponseProto.newBuilder().build();
386386

387-
protected static final GetFileInfoResponseProto VOID_GETFILEINFO_RESPONSE =
388-
GetFileInfoResponseProto.newBuilder().build();
387+
protected static final GetFileInfoResponseProto VOID_GETFILEINFO_RESPONSE =
388+
GetFileInfoResponseProto.newBuilder().build();
389389

390390
protected static final GetLocatedFileInfoResponseProto
391391
VOID_GETLOCATEDFILEINFO_RESPONSE =
392392
GetLocatedFileInfoResponseProto.newBuilder().build();
393393

394-
protected static final GetFileLinkInfoResponseProto VOID_GETFILELINKINFO_RESPONSE =
395-
GetFileLinkInfoResponseProto.newBuilder().build();
394+
protected static final GetFileLinkInfoResponseProto VOID_GETFILELINKINFO_RESPONSE =
395+
GetFileLinkInfoResponseProto.newBuilder().build();
396396

397-
protected static final SetQuotaResponseProto VOID_SETQUOTA_RESPONSE =
398-
SetQuotaResponseProto.newBuilder().build();
397+
protected static final SetQuotaResponseProto VOID_SETQUOTA_RESPONSE =
398+
SetQuotaResponseProto.newBuilder().build();
399399

400-
protected static final FsyncResponseProto VOID_FSYNC_RESPONSE =
401-
FsyncResponseProto.newBuilder().build();
400+
protected static final FsyncResponseProto VOID_FSYNC_RESPONSE =
401+
FsyncResponseProto.newBuilder().build();
402402

403-
protected static final SetTimesResponseProto VOID_SETTIMES_RESPONSE =
404-
SetTimesResponseProto.newBuilder().build();
403+
protected static final SetTimesResponseProto VOID_SETTIMES_RESPONSE =
404+
SetTimesResponseProto.newBuilder().build();
405405

406-
protected static final CreateSymlinkResponseProto VOID_CREATESYMLINK_RESPONSE =
407-
CreateSymlinkResponseProto.newBuilder().build();
406+
protected static final CreateSymlinkResponseProto VOID_CREATESYMLINK_RESPONSE =
407+
CreateSymlinkResponseProto.newBuilder().build();
408408

409-
protected static final UpdatePipelineResponseProto
410-
VOID_UPDATEPIPELINE_RESPONSE =
411-
UpdatePipelineResponseProto.newBuilder().build();
409+
protected static final UpdatePipelineResponseProto VOID_UPDATEPIPELINE_RESPONSE =
410+
UpdatePipelineResponseProto.newBuilder().build();
412411

413-
protected static final CancelDelegationTokenResponseProto
414-
VOID_CANCELDELEGATIONTOKEN_RESPONSE =
415-
CancelDelegationTokenResponseProto.newBuilder().build();
412+
protected static final CancelDelegationTokenResponseProto VOID_CANCELDELEGATIONTOKEN_RESPONSE =
413+
CancelDelegationTokenResponseProto.newBuilder().build();
416414

417-
protected static final SetBalancerBandwidthResponseProto
418-
VOID_SETBALANCERBANDWIDTH_RESPONSE =
419-
SetBalancerBandwidthResponseProto.newBuilder().build();
415+
protected static final SetBalancerBandwidthResponseProto VOID_SETBALANCERBANDWIDTH_RESPONSE =
416+
SetBalancerBandwidthResponseProto.newBuilder().build();
420417

421-
protected static final SetAclResponseProto
422-
VOID_SETACL_RESPONSE = SetAclResponseProto.getDefaultInstance();
418+
protected static final SetAclResponseProto VOID_SETACL_RESPONSE =
419+
SetAclResponseProto.getDefaultInstance();
423420

424-
protected static final ModifyAclEntriesResponseProto
425-
VOID_MODIFYACLENTRIES_RESPONSE = ModifyAclEntriesResponseProto
426-
.getDefaultInstance();
421+
protected static final ModifyAclEntriesResponseProto VOID_MODIFYACLENTRIES_RESPONSE =
422+
ModifyAclEntriesResponseProto.getDefaultInstance();
427423

428-
protected static final RemoveAclEntriesResponseProto
429-
VOID_REMOVEACLENTRIES_RESPONSE = RemoveAclEntriesResponseProto
430-
.getDefaultInstance();
424+
protected static final RemoveAclEntriesResponseProto VOID_REMOVEACLENTRIES_RESPONSE =
425+
RemoveAclEntriesResponseProto.getDefaultInstance();
431426

432-
protected static final RemoveDefaultAclResponseProto
433-
VOID_REMOVEDEFAULTACL_RESPONSE = RemoveDefaultAclResponseProto
434-
.getDefaultInstance();
427+
protected static final RemoveDefaultAclResponseProto VOID_REMOVEDEFAULTACL_RESPONSE =
428+
RemoveDefaultAclResponseProto.getDefaultInstance();
435429

436-
protected static final RemoveAclResponseProto
437-
VOID_REMOVEACL_RESPONSE = RemoveAclResponseProto.getDefaultInstance();
430+
protected static final RemoveAclResponseProto VOID_REMOVEACL_RESPONSE =
431+
RemoveAclResponseProto.getDefaultInstance();
438432

439-
protected static final SetXAttrResponseProto
440-
VOID_SETXATTR_RESPONSE = SetXAttrResponseProto.getDefaultInstance();
433+
protected static final SetXAttrResponseProto VOID_SETXATTR_RESPONSE =
434+
SetXAttrResponseProto.getDefaultInstance();
441435

442-
protected static final RemoveXAttrResponseProto
443-
VOID_REMOVEXATTR_RESPONSE = RemoveXAttrResponseProto.getDefaultInstance();
436+
protected static final RemoveXAttrResponseProto VOID_REMOVEXATTR_RESPONSE =
437+
RemoveXAttrResponseProto.getDefaultInstance();
444438

445-
protected static final CheckAccessResponseProto
446-
VOID_CHECKACCESS_RESPONSE = CheckAccessResponseProto.getDefaultInstance();
439+
protected static final CheckAccessResponseProto VOID_CHECKACCESS_RESPONSE =
440+
CheckAccessResponseProto.getDefaultInstance();
447441

448442
protected static final SatisfyStoragePolicyResponseProto
449443
VOID_SATISFYSTORAGEPOLICY_RESPONSE = SatisfyStoragePolicyResponseProto
450444
.getDefaultInstance();
451445

452-
/**
453-
* Constructor
454-
*
446+
/** Constructor.
455447
* @param server - the NN server
456448
* @throws IOException
457449
*/
@@ -730,7 +722,7 @@ public TruncateResponseProto truncate(RpcController controller,
730722

731723
@Override
732724
public DeleteResponseProto delete(RpcController controller,
733-
DeleteRequestProto req) throws ServiceException {
725+
DeleteRequestProto req) throws ServiceException {
734726
try {
735727
boolean result = server.delete(req.getSrc(), req.getRecursive());
736728
return DeleteResponseProto.newBuilder().setResult(result).build();
@@ -1474,7 +1466,7 @@ public ListCacheDirectivesResponseProto listCacheDirectives(
14741466
CacheDirectiveInfo filter =
14751467
PBHelperClient.convert(request.getFilter());
14761468
BatchedEntries<CacheDirectiveEntry> entries =
1477-
server.listCacheDirectives(request.getPrevId(), filter);
1469+
server.listCacheDirectives(request.getPrevId(), filter);
14781470
ListCacheDirectivesResponseProto.Builder builder =
14791471
ListCacheDirectivesResponseProto.newBuilder();
14801472
builder.setHasMore(entries.hasMore());
@@ -1525,9 +1517,9 @@ public ListCachePoolsResponseProto listCachePools(RpcController controller,
15251517
ListCachePoolsRequestProto request) throws ServiceException {
15261518
try {
15271519
BatchedEntries<CachePoolEntry> entries =
1528-
server.listCachePools(request.getPrevPoolName());
1520+
server.listCachePools(request.getPrevPoolName());
15291521
ListCachePoolsResponseProto.Builder responseBuilder =
1530-
ListCachePoolsResponseProto.newBuilder();
1522+
ListCachePoolsResponseProto.newBuilder();
15311523
responseBuilder.setHasMore(entries.hasMore());
15321524
for (int i=0, n=entries.size(); i<n; i++) {
15331525
responseBuilder.addEntries(PBHelperClient.convert(entries.get(i)));
@@ -1609,8 +1601,8 @@ public GetAclStatusResponseProto getAclStatus(RpcController controller,
16091601

16101602
@Override
16111603
public CreateEncryptionZoneResponseProto createEncryptionZone(
1612-
RpcController controller, CreateEncryptionZoneRequestProto req)
1613-
throws ServiceException {
1604+
RpcController controller, CreateEncryptionZoneRequestProto req)
1605+
throws ServiceException {
16141606
try {
16151607
server.createEncryptionZone(req.getSrc(), req.getKeyName());
16161608
return CreateEncryptionZoneResponseProto.newBuilder().build();
@@ -1638,8 +1630,8 @@ public GetEZForPathResponseProto getEZForPath(
16381630

16391631
@Override
16401632
public ListEncryptionZonesResponseProto listEncryptionZones(
1641-
RpcController controller, ListEncryptionZonesRequestProto req)
1642-
throws ServiceException {
1633+
RpcController controller, ListEncryptionZonesRequestProto req)
1634+
throws ServiceException {
16431635
try {
16441636
BatchedEntries<EncryptionZone> entries = server
16451637
.listEncryptionZones(req.getId());
@@ -1755,7 +1747,7 @@ public GetXAttrsResponseProto getXAttrs(RpcController controller,
17551747

17561748
@Override
17571749
public ListXAttrsResponseProto listXAttrs(RpcController controller,
1758-
ListXAttrsRequestProto req) throws ServiceException {
1750+
ListXAttrsRequestProto req) throws ServiceException {
17591751
try {
17601752
return PBHelperClient.convertListXAttrsResponse(server.listXAttrs(req.getSrc()));
17611753
} catch (IOException e) {
@@ -1776,7 +1768,7 @@ public RemoveXAttrResponseProto removeXAttr(RpcController controller,
17761768

17771769
@Override
17781770
public CheckAccessResponseProto checkAccess(RpcController controller,
1779-
CheckAccessRequestProto req) throws ServiceException {
1771+
CheckAccessRequestProto req) throws ServiceException {
17801772
try {
17811773
server.checkAccess(req.getPath(), PBHelperClient.convert(req.getMode()));
17821774
} catch (IOException e) {
@@ -1869,8 +1861,8 @@ public GetErasureCodingPoliciesResponseProto getErasureCodingPolicies(RpcControl
18691861
GetErasureCodingPoliciesRequestProto request) throws ServiceException {
18701862
try {
18711863
ErasureCodingPolicyInfo[] ecpInfos = server.getErasureCodingPolicies();
1872-
GetErasureCodingPoliciesResponseProto.Builder resBuilder = GetErasureCodingPoliciesResponseProto
1873-
.newBuilder();
1864+
GetErasureCodingPoliciesResponseProto.Builder resBuilder =
1865+
GetErasureCodingPoliciesResponseProto.newBuilder();
18741866
for (ErasureCodingPolicyInfo info : ecpInfos) {
18751867
resBuilder.addEcPolicies(
18761868
PBHelperClient.convertErasureCodingPolicy(info));
@@ -1965,7 +1957,8 @@ public GetErasureCodingPolicyResponseProto getErasureCodingPolicy(RpcController
19651957
GetErasureCodingPolicyRequestProto request) throws ServiceException {
19661958
try {
19671959
ErasureCodingPolicy ecPolicy = server.getErasureCodingPolicy(request.getSrc());
1968-
GetErasureCodingPolicyResponseProto.Builder builder = GetErasureCodingPolicyResponseProto.newBuilder();
1960+
GetErasureCodingPolicyResponseProto.Builder builder =
1961+
GetErasureCodingPolicyResponseProto.newBuilder();
19691962
if (ecPolicy != null) {
19701963
builder.setEcPolicy(PBHelperClient.convertErasureCodingPolicy(ecPolicy));
19711964
}

‎hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/NamenodeProtocolServerSideTranslatorPB.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,11 +73,11 @@ public class NamenodeProtocolServerSideTranslatorPB implements
7373
NamenodeProtocolPB {
7474
private final NamenodeProtocol impl;
7575

76-
protected final static ErrorReportResponseProto VOID_ERROR_REPORT_RESPONSE =
77-
ErrorReportResponseProto.newBuilder().build();
76+
protected final static ErrorReportResponseProto VOID_ERROR_REPORT_RESPONSE =
77+
ErrorReportResponseProto.newBuilder().build();
7878

7979
protected final static EndCheckpointResponseProto VOID_END_CHECKPOINT_RESPONSE =
80-
EndCheckpointResponseProto.newBuilder().build();
80+
EndCheckpointResponseProto.newBuilder().build();
8181

8282
public NamenodeProtocolServerSideTranslatorPB(NamenodeProtocol impl) {
8383
this.impl = impl;

0 commit comments

Comments
 (0)