[ https://issues.apache.org/jira/browse/HADOOP-15327?focusedWorklogId=753341&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-753341 ]
ASF GitHub Bot logged work on HADOOP-15327: ------------------------------------------- Author: ASF GitHub Bot Created on: 06/Apr/22 12:30 Start Date: 06/Apr/22 12:30 Worklog Time Spent: 10m Work Description: szilard-nemeth commented on code in PR #3259: URL: https://github.com/apache/hadoop/pull/3259#discussion_r843887847 ########## hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-shuffle/src/main/java/org/apache/hadoop/mapred/ShuffleHandler.java: ########## @@ -185,12 +187,23 @@ // This should kept in sync with Fetcher.FETCH_RETRY_DELAY_DEFAULT public static final long FETCH_RETRY_DELAY = 1000L; public static final String RETRY_AFTER_HEADER = "Retry-After"; + static final String ENCODER_HANDLER_NAME = "encoder"; private int port; - private ChannelFactory selector; - private final ChannelGroup accepted = new DefaultChannelGroup(); + private EventLoopGroup bossGroup; + private EventLoopGroup workerGroup; + private ServerBootstrap bootstrap; + private Channel ch; + // FIXME: snemeth: need thread safety. - https://stackoverflow.com/questions/17836976/netty-4-0-instanciate-defaultchannelgroup + private final ChannelGroup accepted = + new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); + private final AtomicInteger acceptedConnections = new AtomicInteger(); Review Comment: fixed. Issue Time Tracking ------------------- Worklog Id: (was: 753341) Time Spent: 9h 10m (was: 9h) > Upgrade MR ShuffleHandler to use Netty4 > --------------------------------------- > > Key: HADOOP-15327 > URL: https://issues.apache.org/jira/browse/HADOOP-15327 > Project: Hadoop Common > Issue Type: Sub-task > Reporter: Xiaoyu Yao > Assignee: Szilard Nemeth > Priority: Major > Labels: pull-request-available > Attachments: HADOOP-15327.001.patch, HADOOP-15327.002.patch, > HADOOP-15327.003.patch, HADOOP-15327.004.patch, HADOOP-15327.005.patch, > HADOOP-15327.005.patch, > getMapOutputInfo_BlockingOperationException_awaitUninterruptibly.log, > testfailure-testMapFileAccess-emptyresponse.zip, > testfailure-testReduceFromPartialMem.zip > > Time Spent: 9h 10m > Remaining Estimate: 0h > > This way, we can remove the dependencies on the netty3 (jboss.netty) -- This message was sent by Atlassian Jira (v8.20.1#820001) --------------------------------------------------------------------- To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org