[ https://issues.apache.org/jira/browse/HADOOP-15327?focusedWorklogId=754230&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-754230 ]
ASF GitHub Bot logged work on HADOOP-15327: ------------------------------------------- Author: ASF GitHub Bot Created on: 07/Apr/22 16:44 Start Date: 07/Apr/22 16:44 Worklog Time Spent: 10m Work Description: szilard-nemeth commented on code in PR #3259: URL: https://github.com/apache/hadoop/pull/3259#discussion_r845361546 ########## 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); Review Comment: Fixed, please check again. Issue Time Tracking ------------------- Worklog Id: (was: 754230) Time Spent: 10h (was: 9h 50m) > 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: 10h > 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