Repository: hadoop Updated Branches: refs/heads/yarn-native-services 7475dcc57 -> f53aa3e49
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/f53aa3e4 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f53aa3e4 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f53aa3e4 Branch: refs/heads/yarn-native-services Commit: f53aa3e4913954de09d9cd4ef9d8d8965560b51f Parents: 7475dcc Author: Billie Rinaldi <[email protected]> Authored: Wed Oct 25 13:01:01 2017 -0700 Committer: Billie Rinaldi <[email protected]> Committed: Wed Oct 25 13:01:01 2017 -0700 ---------------------------------------------------------------------- .../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/f53aa3e4/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: [email protected] For additional commands, e-mail: [email protected]
