Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HADOOP-7858. Drop some info logging to DEBUG level in IPC, metrics, and HTTP. Contributed by Todd Lipcon 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1206830 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Eli Collins 2011-11-27 20:27:23 +00:00
parent cb5c6c90c4
commit 229a3a2312
5 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-common-project/hadoop-common/CHANGES.txt
View File

@ -123,6 +123,9 @@ Release 0.23.1 - Unreleased
HADOOP-7802. Hadoop scripts unconditionally source HADOOP-7802. Hadoop scripts unconditionally source
"$bin"/../libexec/hadoop-config.sh. (Bruno Mahé via tomwhite) "$bin"/../libexec/hadoop-config.sh. (Bruno Mahé via tomwhite)
HADOOP-7858. Drop some info logging to DEBUG level in IPC,
metrics, and HTTP. (todd via eli)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

4
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java
View File

@ -644,12 +644,12 @@ public class HttpServer implements FilterContainer {
while (true) { while (true) {
try { try {
port = webServer.getConnectors()[0].getLocalPort(); port = webServer.getConnectors()[0].getLocalPort();
LOG.info("Port returned by webServer.getConnectors()[0]." + LOG.debug("Port returned by webServer.getConnectors()[0]." +
"getLocalPort() before open() is "+ port + "getLocalPort() before open() is "+ port +
". Opening the listener on " + oriPort); ". Opening the listener on " + oriPort);
listener.open(); listener.open();
port = listener.getLocalPort(); port = listener.getLocalPort();
LOG.info("listener.getLocalPort() returned " + listener.getLocalPort() + LOG.debug("listener.getLocalPort() returned " + listener.getLocalPort() +
" webServer.getConnectors()[0].getLocalPort() returned " + " webServer.getConnectors()[0].getLocalPort() returned " +
webServer.getConnectors()[0].getLocalPort()); webServer.getConnectors()[0].getLocalPort());
//Workaround to handle the problem reported in HADOOP-4744 //Workaround to handle the problem reported in HADOOP-4744

4
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java
View File

@ -1498,7 +1498,7 @@ public abstract class Server {
@Override @Override
public void run() { public void run() {
LOG.info(getName() + ": starting"); LOG.debug(getName() + ": starting");
SERVER.set(Server.this); SERVER.set(Server.this);
ByteArrayOutputStream buf = ByteArrayOutputStream buf =
new ByteArrayOutputStream(INITIAL_RESP_BUF_SIZE); new ByteArrayOutputStream(INITIAL_RESP_BUF_SIZE);
@ -1580,7 +1580,7 @@ public abstract class Server {
LOG.info(getName() + " caught an exception", e); LOG.info(getName() + " caught an exception", e);
} }
} }
LOG.info(getName() + ": exiting"); LOG.debug(getName() + ": exiting");
} }
} }

2
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/WritableRpcEngine.java
View File

@ -389,7 +389,7 @@ public class WritableRpcEngine implements RpcEngine {
} }
protocolImplMap.put(new ProtoNameVer(protocolName, version), protocolImplMap.put(new ProtoNameVer(protocolName, version),
new ProtoClassProtoImpl(protocolClass, protocolImpl)); new ProtoClassProtoImpl(protocolClass, protocolImpl));
LOG.info("Protocol Name = " + protocolName + " version=" + version + LOG.debug("Protocol Name = " + protocolName + " version=" + version +
" ProtocolImpl=" + protocolImpl.getClass().getName() + " ProtocolImpl=" + protocolImpl.getClass().getName() +
" protocolClass=" + protocolClass.getName()); " protocolClass=" + protocolClass.getName());
} }

10
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl/MetricsSystemImpl.java
View File

@ -241,7 +241,7 @@ public class MetricsSystemImpl extends MetricsSystem implements MetricsSource {
injectedTags, period, config.subset(SOURCE_KEY)); injectedTags, period, config.subset(SOURCE_KEY));
sources.put(name, sa); sources.put(name, sa);
sa.start(); sa.start();
LOG.info("Registered source "+ name); LOG.debug("Registered source "+ name);
} }
@Override public synchronized <T extends MetricsSink> @Override public synchronized <T extends MetricsSink>
@ -405,8 +405,8 @@ public class MetricsSystemImpl extends MetricsSystem implements MetricsSource {
private synchronized void stopSources() { private synchronized void stopSources() {
for (Entry<String, MetricsSourceAdapter> entry : sources.entrySet()) { for (Entry<String, MetricsSourceAdapter> entry : sources.entrySet()) {
MetricsSourceAdapter sa = entry.getValue(); MetricsSourceAdapter sa = entry.getValue();
LOG.info("Stopping metrics source "+ entry.getKey()); LOG.debug("Stopping metrics source "+ entry.getKey() +
LOG.debug(sa.source().getClass()); ": class=" + sa.source().getClass());
sa.stop(); sa.stop();
} }
sysSource.stop(); sysSource.stop();
@ -416,8 +416,8 @@ public class MetricsSystemImpl extends MetricsSystem implements MetricsSource {
private synchronized void stopSinks() { private synchronized void stopSinks() {
for (Entry<String, MetricsSinkAdapter> entry : sinks.entrySet()) { for (Entry<String, MetricsSinkAdapter> entry : sinks.entrySet()) {
MetricsSinkAdapter sa = entry.getValue(); MetricsSinkAdapter sa = entry.getValue();
LOG.info("Stopping metrics sink "+ entry.getKey()); LOG.debug("Stopping metrics sink "+ entry.getKey() +
LOG.debug(sa.sink().getClass()); ": class=" + sa.sink().getClass());
sa.stop(); sa.stop();
} }
sinks.clear(); sinks.clear();