YARN-7351. Fix high CPU usage issue in RegistryDNS. Contributed by Jian He
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d2775fbc Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d2775fbc Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d2775fbc Branch: refs/heads/trunk Commit: d2775fbccaa187729d86459542210434ce4c3b8b Parents: 501be9b Author: Billie Rinaldi <bil...@apache.org> Authored: Wed Oct 25 13:01:01 2017 -0700 Committer: Jian He <jia...@apache.org> Committed: Mon Nov 6 13:30:19 2017 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/registry/server/dns/RegistryDNS.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d2775fbc/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-registry/src/main/java/org/apache/hadoop/registry/server/dns/RegistryDNS.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-registry/src/main/java/org/apache/hadoop/registry/server/dns/RegistryDNS.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-registry/src/main/java/org/apache/hadoop/registry/server/dns/RegistryDNS.java index 37e8429..9097c46 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-registry/src/main/java/org/apache/hadoop/registry/server/dns/RegistryDNS.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-registry/src/main/java/org/apache/hadoop/registry/server/dns/RegistryDNS.java @@ -189,7 +189,8 @@ public class RegistryDNS extends AbstractService implements DNSOperations, LOG.info("Opening TCP and UDP channels on {} port {}", addr, port); addNIOUDP(addr, port); - addNIOTCP(addr, port); + //TODO Fix dns lookup over TCP +// addNIOTCP(addr, port); } /** @@ -770,6 +771,7 @@ public class RegistryDNS extends AbstractService implements DNSOperations, byte[] response = null; try { query = new Message(in); + LOG.info("received TCP query {}", query.getQuestion()); response = generateReply(query, ch.socket()); if (response == null) { return; @@ -947,7 +949,7 @@ public class RegistryDNS extends AbstractService implements DNSOperations, input.flip(); input.get(in); query = new Message(in); - LOG.info("{}: received query {}", remoteAddress, + LOG.info("{}: received UDP query {}", remoteAddress, query.getQuestion()); response = generateReply(query, null); if (response == null) { @@ -960,7 +962,7 @@ public class RegistryDNS extends AbstractService implements DNSOperations, output.put(response); output.flip(); - LOG.info("{}: sending response", remoteAddress); + LOG.debug("{}: sending response", remoteAddress); channel.send(output, remoteAddress); } } catch (Exception e) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
