HADOOP-15254. Correct the wrong word spelling 'intialize'. Contributed by fang zhenyi.
This commit is contained in:
parent
c30a26abc5
commit
2fa7963c3d
@ -103,7 +103,7 @@ public class Log4Json extends Layout {
|
|||||||
/**
|
/**
|
||||||
* Jackson factories are thread safe when constructing parsers and generators.
|
* Jackson factories are thread safe when constructing parsers and generators.
|
||||||
* They are not thread safe in configure methods; if there is to be any
|
* They are not thread safe in configure methods; if there is to be any
|
||||||
* configuration it must be done in a static intializer block.
|
* configuration it must be done in a static initializer block.
|
||||||
*/
|
*/
|
||||||
private static final JsonFactory factory = new MappingJsonFactory();
|
private static final JsonFactory factory = new MappingJsonFactory();
|
||||||
private static final ObjectReader READER = new ObjectMapper(factory).reader();
|
private static final ObjectReader READER = new ObjectMapper(factory).reader();
|
||||||
|
@ -152,7 +152,7 @@ public void contextInitialized(ServletContextEvent sce) {
|
|||||||
|
|
||||||
kmsAudit = new KMSAudit(kmsConf);
|
kmsAudit = new KMSAudit(kmsConf);
|
||||||
|
|
||||||
// intializing the KeyProvider
|
// initializing the KeyProvider
|
||||||
String providerString = kmsConf.get(KMSConfiguration.KEY_PROVIDER_URI);
|
String providerString = kmsConf.get(KMSConfiguration.KEY_PROVIDER_URI);
|
||||||
if (providerString == null) {
|
if (providerString == null) {
|
||||||
throw new IllegalStateException("No KeyProvider has been defined");
|
throw new IllegalStateException("No KeyProvider has been defined");
|
||||||
|
@ -73,7 +73,7 @@ public boolean init(final Configuration config, final String id,
|
|||||||
|
|
||||||
boolean success = initDriver();
|
boolean success = initDriver();
|
||||||
if (!success) {
|
if (!success) {
|
||||||
LOG.error("Cannot intialize driver for {}", getDriverName());
|
LOG.error("Cannot initialize driver for {}", getDriverName());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -240,7 +240,7 @@ static DatanodeInfo chooseDatanode(final NameNode namenode,
|
|||||||
final String remoteAddr, final HdfsFileStatus status) throws IOException {
|
final String remoteAddr, final HdfsFileStatus status) throws IOException {
|
||||||
FSNamesystem fsn = namenode.getNamesystem();
|
FSNamesystem fsn = namenode.getNamesystem();
|
||||||
if (fsn == null) {
|
if (fsn == null) {
|
||||||
throw new IOException("Namesystem has not been intialized yet.");
|
throw new IOException("Namesystem has not been initialized yet.");
|
||||||
}
|
}
|
||||||
final BlockManager bm = fsn.getBlockManager();
|
final BlockManager bm = fsn.getBlockManager();
|
||||||
|
|
||||||
|
@ -243,7 +243,7 @@ public void testChooseDatanodeBeforeNamesystemInit() throws Exception {
|
|||||||
NameNode nn = mock(NameNode.class);
|
NameNode nn = mock(NameNode.class);
|
||||||
when(nn.getNamesystem()).thenReturn(null);
|
when(nn.getNamesystem()).thenReturn(null);
|
||||||
exception.expect(IOException.class);
|
exception.expect(IOException.class);
|
||||||
exception.expectMessage("Namesystem has not been intialized yet.");
|
exception.expectMessage("Namesystem has not been initialized yet.");
|
||||||
NamenodeWebHdfsMethods.chooseDatanode(nn, "/path", PutOpParam.Op.CREATE, 0,
|
NamenodeWebHdfsMethods.chooseDatanode(nn, "/path", PutOpParam.Op.CREATE, 0,
|
||||||
DFSConfigKeys.DFS_BLOCK_SIZE_DEFAULT, null, LOCALHOST, null);
|
DFSConfigKeys.DFS_BLOCK_SIZE_DEFAULT, null, LOCALHOST, null);
|
||||||
}
|
}
|
||||||
|
@ -1255,7 +1255,7 @@ protected void serviceStart() throws Exception {
|
|||||||
|
|
||||||
boolean initFailed = false;
|
boolean initFailed = false;
|
||||||
if (!errorHappenedShutDown) {
|
if (!errorHappenedShutDown) {
|
||||||
// create a job event for job intialization
|
// create a job event for job initialization
|
||||||
JobEvent initJobEvent = new JobEvent(job.getID(), JobEventType.JOB_INIT);
|
JobEvent initJobEvent = new JobEvent(job.getID(), JobEventType.JOB_INIT);
|
||||||
// Send init to the job (this does NOT trigger job execution)
|
// Send init to the job (this does NOT trigger job execution)
|
||||||
// This is a synchronous call, not an event through dispatcher. We want
|
// This is a synchronous call, not an event through dispatcher. We want
|
||||||
|
@ -98,7 +98,7 @@ protected void serviceInit(Configuration conf) throws Exception {
|
|||||||
try {
|
try {
|
||||||
hsManager.initExisting();
|
hsManager.initExisting();
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
throw new YarnRuntimeException("Failed to intialize existing directories", e);
|
throw new YarnRuntimeException("Failed to initialize existing directories", e);
|
||||||
}
|
}
|
||||||
|
|
||||||
storage = createHistoryStorage();
|
storage = createHistoryStorage();
|
||||||
|
@ -154,7 +154,7 @@ static public JobConf createJob(String[] argv) throws IOException {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* This is the method that actually
|
* This is the method that actually
|
||||||
* intializes the job conf and submits the job
|
* initializes the job conf and submits the job
|
||||||
* to the jobtracker
|
* to the jobtracker
|
||||||
* @throws IOException
|
* @throws IOException
|
||||||
* @deprecated use {@link #run(String[])} instead.
|
* @deprecated use {@link #run(String[])} instead.
|
||||||
|
@ -117,7 +117,7 @@ private List<TempQueuePerPartition> getPathToRoot(TempQueuePerPartition tq) {
|
|||||||
return list;
|
return list;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void intializePriorityDigraph() {
|
private void initializePriorityDigraph() {
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("Initializing priority preemption directed graph:");
|
LOG.debug("Initializing priority preemption directed graph:");
|
||||||
}
|
}
|
||||||
@ -383,7 +383,7 @@ public Map<ApplicationAttemptId, Set<RMContainer>> selectCandidates(
|
|||||||
// Initialize digraph from queues
|
// Initialize digraph from queues
|
||||||
// TODO (wangda): only do this when queue refreshed.
|
// TODO (wangda): only do this when queue refreshed.
|
||||||
priorityDigraph.clear();
|
priorityDigraph.clear();
|
||||||
intializePriorityDigraph();
|
initializePriorityDigraph();
|
||||||
|
|
||||||
// When all queues are set to same priority, or priority is not respected,
|
// When all queues are set to same priority, or priority is not respected,
|
||||||
// direct return.
|
// direct return.
|
||||||
|
@ -540,7 +540,7 @@ protected RMNodeLabelsManager createNodeLabelManager() {
|
|||||||
try {
|
try {
|
||||||
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
Assert.fail("Caught Exception while intializing");
|
Assert.fail("Caught Exception while initializing");
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -589,7 +589,7 @@ protected RMNodeLabelsManager createNodeLabelManager() {
|
|||||||
try {
|
try {
|
||||||
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("X", "Y", "Z"));
|
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("X", "Y", "Z"));
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
Assert.fail("Caught Exception while intializing");
|
Assert.fail("Caught Exception while initializing");
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -642,7 +642,7 @@ protected RMNodeLabelsManager createNodeLabelManager() {
|
|||||||
try {
|
try {
|
||||||
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("X", "Y", "Z"));
|
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("X", "Y", "Z"));
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
Assert.fail("Caught Exception while intializing");
|
Assert.fail("Caught Exception while initializing");
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -694,7 +694,7 @@ protected RMNodeLabelsManager createNodeLabelManager() {
|
|||||||
try {
|
try {
|
||||||
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
Assert.fail("Caught Exception while intializing");
|
Assert.fail("Caught Exception while initializing");
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
ResourceTrackerService resourceTrackerService =
|
ResourceTrackerService resourceTrackerService =
|
||||||
@ -754,7 +754,7 @@ protected RMNodeLabelsManager createNodeLabelManager() {
|
|||||||
try {
|
try {
|
||||||
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
Assert.fail("Caught Exception while intializing");
|
Assert.fail("Caught Exception while initializing");
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -839,7 +839,7 @@ protected RMNodeLabelsManager createNodeLabelManager() {
|
|||||||
try {
|
try {
|
||||||
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
nodeLabelsMgr.addToCluserNodeLabelsWithDefaultExclusivity(toSet("A", "B", "C"));
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
Assert.fail("Caught Exception while intializing");
|
Assert.fail("Caught Exception while initializing");
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user