|
@@ -331,7 +331,8 @@ class BPOfferService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- synchronized DatanodeRegistration createRegistration() {
|
|
|
+ synchronized DatanodeRegistration createRegistration()
|
|
|
+ throws IOException {
|
|
|
Preconditions.checkState(bpNSInfo != null,
|
|
|
"getRegistration() can only be called after initial handshake");
|
|
|
return dn.createBPRegistration(bpNSInfo);
|