We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 34c264c commit e02750eCopy full SHA for e02750e
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/SocketIOWithTimeout.java
@@ -390,7 +390,7 @@ private static SelectorInfo get(SelectableChannel channel) throws IOException {
390
ConcurrentLinkedDeque<SelectorInfo> selectorQ = providerMap.computeIfAbsent(
391
provider, k -> new ConcurrentLinkedDeque<>());
392
393
- SelectorInfo selInfo = selectorQ.removeLast(); // last in first out
+ SelectorInfo selInfo = selectorQ.pollLast(); // last in first out
394
if (selInfo == null) {
395
Selector selector = provider.openSelector();
396
// selInfo will be put into selectorQ after `#release()`
0 commit comments