HDFS-15160. amend to fix javac error supressing unchecked warning
This commit is contained in:
parent
38973a52f0
commit
0d0f344d65
|
@ -201,16 +201,16 @@ class FsDatasetImpl implements FsDatasetSpi<FsVolumeImpl> {
|
||||||
* The deepCopyReplica call doesn't use the datasetock since it will lead the
|
* The deepCopyReplica call doesn't use the datasetock since it will lead the
|
||||||
* potential deadlock with the {@link FsVolumeList#addBlockPool} call.
|
* potential deadlock with the {@link FsVolumeList#addBlockPool} call.
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
@Override
|
@Override
|
||||||
public Set<? extends Replica> deepCopyReplica(String bpid)
|
public Set<? extends Replica> deepCopyReplica(String bpid)
|
||||||
throws IOException {
|
throws IOException {
|
||||||
Set<? extends Replica> replicas = null;
|
Set<? extends Replica> replicas;
|
||||||
try (AutoCloseableLock lock = datasetReadLock.acquire()) {
|
try (AutoCloseableLock lock = datasetReadLock.acquire()) {
|
||||||
replicas =
|
replicas =
|
||||||
new HashSet<>(volumeMap.replicas(bpid) == null ? Collections.EMPTY_SET
|
new HashSet<>(volumeMap.replicas(bpid) == null ? Collections.EMPTY_SET
|
||||||
: volumeMap.replicas(bpid));
|
: volumeMap.replicas(bpid));
|
||||||
}
|
}
|
||||||
|
|
||||||
return Collections.unmodifiableSet(replicas);
|
return Collections.unmodifiableSet(replicas);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue