big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HADOOP-18433. Fix main thread name for . (#4838)

Browse Source
This commit is contained in:
zhengchenyu 2022-11-09 19:18:31 +08:00 committed by GitHub
parent 7002e214b8
commit f68f1a4578
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1393,8 +1393,7 @@ private class Listener extends Thread {
bind(acceptChannel.socket(), address, backlogLength, conf, portRangeConfig); bind(acceptChannel.socket(), address, backlogLength, conf, portRangeConfig);
//Could be an ephemeral port //Could be an ephemeral port
this.listenPort = acceptChannel.socket().getLocalPort(); this.listenPort = acceptChannel.socket().getLocalPort();
Thread.currentThread().setName("Listener at " + LOG.info("Listener at {}:{}", bindAddress, this.listenPort);
bindAddress + "/" + this.listenPort);
// create a selector; // create a selector;
selector= Selector.open(); selector= Selector.open();
readers = new Reader[readThreads]; readers = new Reader[readThreads];