HADOOP-17035. fixed typos (timeout, interruped) (#2007)
Co-authored-by: Sungpeo Kook <elixir.kook@kakaocorp.com>
This commit is contained in:
parent
047d8879e7
commit
a3f945fb84
@ -40,7 +40,7 @@
|
|||||||
import static org.junit.Assert.*;
|
import static org.junit.Assert.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This tests timout out from SocketInputStream and
|
* This tests timeout out from SocketInputStream and
|
||||||
* SocketOutputStream using pipes.
|
* SocketOutputStream using pipes.
|
||||||
*
|
*
|
||||||
* Normal read and write using these streams are tested by pretty much
|
* Normal read and write using these streams are tested by pretty much
|
||||||
|
@ -3431,7 +3431,7 @@ public void checkDiskError() throws IOException {
|
|||||||
unhealthyVolumes = volumeChecker.checkAllVolumes(data);
|
unhealthyVolumes = volumeChecker.checkAllVolumes(data);
|
||||||
lastDiskErrorCheck = Time.monotonicNow();
|
lastDiskErrorCheck = Time.monotonicNow();
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
LOG.error("Interruped while running disk check", e);
|
LOG.error("Interrupted while running disk check", e);
|
||||||
throw new IOException("Interrupted while running disk check", e);
|
throw new IOException("Interrupted while running disk check", e);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -225,7 +225,7 @@ public MRClientProtocol run() throws IOException {
|
|||||||
try {
|
try {
|
||||||
Thread.sleep(2000);
|
Thread.sleep(2000);
|
||||||
} catch (InterruptedException e1) {
|
} catch (InterruptedException e1) {
|
||||||
LOG.warn("getProxy() call interruped", e1);
|
LOG.warn("getProxy() call interrupted", e1);
|
||||||
throw new YarnRuntimeException(e1);
|
throw new YarnRuntimeException(e1);
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
@ -239,7 +239,7 @@ public MRClientProtocol run() throws IOException {
|
|||||||
return checkAndGetHSProxy(null, JobState.RUNNING);
|
return checkAndGetHSProxy(null, JobState.RUNNING);
|
||||||
}
|
}
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
LOG.warn("getProxy() call interruped", e);
|
LOG.warn("getProxy() call interrupted", e);
|
||||||
throw new YarnRuntimeException(e);
|
throw new YarnRuntimeException(e);
|
||||||
} catch (YarnException e) {
|
} catch (YarnException e) {
|
||||||
throw new IOException(e);
|
throw new IOException(e);
|
||||||
|
@ -58,7 +58,7 @@ Features
|
|||||||
`yarn rmadmin -refreshNodes [-g [timeout in seconds] -client|server]` notifies NodesListManager to detect and handle include and exclude hosts changes. NodesListManager loads excluded hosts from the exclude file as specified through the `yarn.resourcemanager.nodes.exclude-path` configuration in yarn-site.xml. (Note: It is unnecessary to restart RM in case of changing the exclude-path
|
`yarn rmadmin -refreshNodes [-g [timeout in seconds] -client|server]` notifies NodesListManager to detect and handle include and exclude hosts changes. NodesListManager loads excluded hosts from the exclude file as specified through the `yarn.resourcemanager.nodes.exclude-path` configuration in yarn-site.xml. (Note: It is unnecessary to restart RM in case of changing the exclude-path
|
||||||
as this config will be read again for every `refreshNodes` command)
|
as this config will be read again for every `refreshNodes` command)
|
||||||
|
|
||||||
The format of the file could be plain text or XML depending the extension of the file. Only the XML format supports per node timout for graceful decommissioning.
|
The format of the file could be plain text or XML depending the extension of the file. Only the XML format supports per node timeout for graceful decommissioning.
|
||||||
|
|
||||||
NodesListManager inspects and compares status of RMNodes in resource manager and the exclude list, and apply necessary actions based on following rules:
|
NodesListManager inspects and compares status of RMNodes in resource manager and the exclude list, and apply necessary actions based on following rules:
|
||||||
|
|
||||||
@ -83,7 +83,7 @@ In case of server side timeout:
|
|||||||
2. Use the timeout in `yarn rmadmin -refreshNodes -g [timeout in seconds] -server|client` if specified;
|
2. Use the timeout in `yarn rmadmin -refreshNodes -g [timeout in seconds] -server|client` if specified;
|
||||||
3. Use the default timeout specified through *"yarn.resourcemanager.nodemanager-graceful-decommission-timeout-secs"* configuration.
|
3. Use the default timeout specified through *"yarn.resourcemanager.nodemanager-graceful-decommission-timeout-secs"* configuration.
|
||||||
|
|
||||||
In case of client side timout (see bellow):
|
In case of client side timeout (see bellow):
|
||||||
|
|
||||||
1. Only the command line parameter defined by the `-g` flag will be used.
|
1. Only the command line parameter defined by the `-g` flag will be used.
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user