Skip to content

Commit 08ce676

Browse files
aswinmprabhuAswin M Prabhu
authored andcommitted
Address review comments
1 parent 0c61a9f commit 08ce676

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/JournalNodeRpcServer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ public GetEditLogManifestResponseProto getEditLogManifest(
260260
@Override
261261
public StorageInfoProto getStorageInfo(String jid,
262262
String nameServiceId) throws IOException {
263-
StorageInfo storage = jn.getOrCreateJournal(jid).getStorage();
263+
StorageInfo storage = jn.getOrCreateJournal(jid, nameServiceId).getStorage();
264264
return PBHelper.convert(storage);
265265
}
266266

hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/JournalNodeSyncer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ private void formatWithSyncer() {
267267
}
268268
try {
269269
HdfsServerProtos.StorageInfoProto storageInfoResponse =
270-
jnProxy.jnProxy.getStorageInfo(jid, null);
270+
jnProxy.jnProxy.getStorageInfo(jid, nameServiceId);
271271
storage = PBHelper.convert(
272272
storageInfoResponse, HdfsServerConstants.NodeType.JOURNAL_NODE
273273
);

0 commit comments

Comments
 (0)