diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java index cb920bcc0091..280afc05e89e 100644 --- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java +++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java @@ -1793,7 +1793,7 @@ public OzoneDataStreamOutput createMultipartStreamKey( .setMultipartUploadID(uploadID) .setIsMultipartKey(true) .enableUnsafeByteBufferConversion(unsafeByteBufferConversion) - .setConfig(clientConfig) + .setConfig(conf.getObject(OzoneClientConfig.class)) .build(); keyOutputStream .addPreallocateBlocks( @@ -2184,7 +2184,7 @@ private OzoneDataStreamOutput createDataStreamOutput(OpenKeySession openKey, .setRequestID(requestId) .setReplicationConfig(replicationConfig) .enableUnsafeByteBufferConversion(unsafeByteBufferConversion) - .setConfig(clientConfig) + .setConfig(conf.getObject(OzoneClientConfig.class)) .build(); keyOutputStream .addPreallocateBlocks(openKey.getKeyInfo().getLatestVersionLocations(), @@ -2254,7 +2254,7 @@ private KeyOutputStream.Builder createKeyOutputStream(OpenKeySession openKey, .setOmClient(ozoneManagerClient) .setRequestID(requestId) .enableUnsafeByteBufferConversion(unsafeByteBufferConversion) - .setConfig(clientConfig) + .setConfig(conf.getObject(OzoneClientConfig.class)) .setClientMetrics(clientMetrics); }