Jihoon Son created TAJO-1578:
--------------------------------
Summary: User configuration for pull server port is ignored.
Key: TAJO-1578
URL: https://issues.apache.org/jira/browse/TAJO-1578
Project: Tajo
Issue Type: Bug
Reporter: Jihoon Son
See the title.
When TajoPullServerService is initialized, it overwrites user-configured pull
server port with the default value as follows.
{code}
...
@Override
public void init(Configuration conf) {
try {
manageOsCache = conf.getBoolean(SHUFFLE_MANAGE_OS_CACHE,
DEFAULT_SHUFFLE_MANAGE_OS_CACHE);
readaheadLength = conf.getInt(SHUFFLE_READAHEAD_BYTES,
DEFAULT_SHUFFLE_READAHEAD_BYTES);
int workerNum = conf.getInt("tajo.shuffle.rpc.server.worker-thread-num",
Runtime.getRuntime().availableProcessors() * 2);
selector =
RpcChannelFactory.createServerChannelFactory("TajoPullServerService", workerNum)
.option(ChannelOption.TCP_NODELAY, true)
.childOption(ChannelOption.ALLOCATOR,
PooledByteBufAllocator.DEFAULT)
.childOption(ChannelOption.TCP_NODELAY, true);
localFS = new LocalFileSystem();
conf.setInt(TajoConf.ConfVars.PULLSERVER_PORT.varname
, TajoConf.ConfVars.PULLSERVER_PORT.defaultIntVal);
super.init(conf);
LOG.info("Tajo PullServer initialized: readaheadLength=" +
readaheadLength);
} catch (Throwable t) {
LOG.error(t, t);
}
}
...
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
