HDFS-10349. Ozone: StorageContainerManager fails to compile after merge of HDFS-10312 maxDataLength enforcement. Contributed by Chris Nauroth.
This commit is contained in:
parent
7d661a289a
commit
acf0b220ce
|
@ -18,6 +18,8 @@
|
||||||
|
|
||||||
package org.apache.hadoop.ozone.storage;
|
package org.apache.hadoop.ozone.storage;
|
||||||
|
|
||||||
|
import static org.apache.hadoop.fs.CommonConfigurationKeys.IPC_MAXIMUM_DATA_LENGTH;
|
||||||
|
import static org.apache.hadoop.fs.CommonConfigurationKeys.IPC_MAXIMUM_DATA_LENGTH_DEFAULT;
|
||||||
import static org.apache.hadoop.fs.CommonConfigurationKeysPublic.FS_DEFAULT_NAME_KEY;
|
import static org.apache.hadoop.fs.CommonConfigurationKeysPublic.FS_DEFAULT_NAME_KEY;
|
||||||
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HANDLER_COUNT_DEFAULT;
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HANDLER_COUNT_DEFAULT;
|
||||||
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HANDLER_COUNT_KEY;
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HANDLER_COUNT_KEY;
|
||||||
|
@ -154,11 +156,13 @@ public class StorageContainerManager
|
||||||
RPC.setProtocolEngine(conf, StorageContainerLocationProtocolPB.class,
|
RPC.setProtocolEngine(conf, StorageContainerLocationProtocolPB.class,
|
||||||
ProtobufRpcEngine.class);
|
ProtobufRpcEngine.class);
|
||||||
|
|
||||||
|
int maxDataLength = conf.getInt(IPC_MAXIMUM_DATA_LENGTH,
|
||||||
|
IPC_MAXIMUM_DATA_LENGTH_DEFAULT);
|
||||||
BlockingService dnProtoPbService =
|
BlockingService dnProtoPbService =
|
||||||
DatanodeProtocolProtos
|
DatanodeProtocolProtos
|
||||||
.DatanodeProtocolService
|
.DatanodeProtocolService
|
||||||
.newReflectiveBlockingService(
|
.newReflectiveBlockingService(
|
||||||
new DatanodeProtocolServerSideTranslatorPB(this));
|
new DatanodeProtocolServerSideTranslatorPB(this, maxDataLength));
|
||||||
|
|
||||||
InetSocketAddress serviceRpcAddr = NameNode.getServiceAddress(conf, false);
|
InetSocketAddress serviceRpcAddr = NameNode.getServiceAddress(conf, false);
|
||||||
serviceRpcServer = startRpcServer(conf, serviceRpcAddr,
|
serviceRpcServer = startRpcServer(conf, serviceRpcAddr,
|
||||||
|
|
Loading…
Reference in New Issue