|
@@ -2745,7 +2745,8 @@ public class MiniDFSCluster implements AutoCloseable {
|
|
|
final DataNode dn = dataNodes.get(dataNodeIndex).datanode;
|
|
|
final FsDatasetSpi<?> dataSet = DataNodeTestUtils.getFSDataset(dn);
|
|
|
if (!(dataSet instanceof SimulatedFSDataset)) {
|
|
|
- throw new IOException("injectBlocks is valid only for SimilatedFSDataset");
|
|
|
+ throw new IOException("injectBlocks is valid only for" +
|
|
|
+ " SimulatedFSDataset");
|
|
|
}
|
|
|
if (bpid == null) {
|
|
|
bpid = getNamesystem().getBlockPoolId();
|
|
@@ -2766,7 +2767,8 @@ public class MiniDFSCluster implements AutoCloseable {
|
|
|
final DataNode dn = dataNodes.get(dataNodeIndex).datanode;
|
|
|
final FsDatasetSpi<?> dataSet = DataNodeTestUtils.getFSDataset(dn);
|
|
|
if (!(dataSet instanceof SimulatedFSDataset)) {
|
|
|
- throw new IOException("injectBlocks is valid only for SimilatedFSDataset");
|
|
|
+ throw new IOException("injectBlocks is valid only for" +
|
|
|
+ " SimulatedFSDataset");
|
|
|
}
|
|
|
String bpid = getNamesystem(nameNodeIndex).getBlockPoolId();
|
|
|
SimulatedFSDataset sdataset = (SimulatedFSDataset) dataSet;
|