This is an automated email from the ASF dual-hosted git repository.
peterxcli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 8b75dcf0905 HDDS-16820. Speed up TestBlockOutputStreamCorrectness
(#11457)
8b75dcf0905 is described below
commit 8b75dcf09051211cb1bce0afa3db408737ba0df3
Author: Doroszlai, Attila <[email protected]>
AuthorDate: Sat Oct 10 10:51:10 2026 +0200
HDDS-16820. Speed up TestBlockOutputStreamCorrectness (#11457)
---
.../hdds/scm/storage/TestBlockOutputStreamCorrectness.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/hadoop-hdds/client/src/test/java/org/apache/hadoop/hdds/scm/storage/TestBlockOutputStreamCorrectness.java
b/hadoop-hdds/client/src/test/java/org/apache/hadoop/hdds/scm/storage/TestBlockOutputStreamCorrectness.java
index 745cb0343a3..edc58b4d19c 100644
---
a/hadoop-hdds/client/src/test/java/org/apache/hadoop/hdds/scm/storage/TestBlockOutputStreamCorrectness.java
+++
b/hadoop-hdds/client/src/test/java/org/apache/hadoop/hdds/scm/storage/TestBlockOutputStreamCorrectness.java
@@ -69,7 +69,7 @@
*/
class TestBlockOutputStreamCorrectness {
- private static final int DATA_SIZE = 256 * (int) OzoneConsts.MB;
+ private static final int DATA_SIZE = 16 * (int) OzoneConsts.MB;
private static final byte[] DATA =
RandomUtils.secure().randomBytes(DATA_SIZE);
@ParameterizedTest
@@ -77,7 +77,7 @@ class TestBlockOutputStreamCorrectness {
void test(final int writeSize) throws IOException {
assertEquals(0, DATA_SIZE % writeSize);
- final BufferPool bufferPool = new BufferPool(4 * 1024 * 1024, 32 / 4);
+ final BufferPool bufferPool = new BufferPool(1024 * 1024 / 4, 32 / 4);
for (int block = 0; block < 10; block++) {
try (BlockOutputStream outputStream =
createBlockOutputStream(bufferPool)) {
@@ -202,12 +202,12 @@ private BlockOutputStream
createBlockOutputStream(BufferPool bufferPool)
.thenReturn(new MockXceiverClientSpi(pipeline));
OzoneClientConfig config = new OzoneClientConfig();
- config.setStreamBufferSize(4 * 1024 * 1024);
- config.setStreamBufferMaxSize(32 * 1024 * 1024);
+ config.setStreamBufferSize(1024 * 1024 / 4);
+ config.setStreamBufferMaxSize(2 * 1024 * 1024);
config.setStreamBufferFlushDelay(true);
- config.setStreamBufferFlushSize(16 * 1024 * 1024);
+ config.setStreamBufferFlushSize(1024 * 1024);
config.setChecksumType(ChecksumType.NONE);
- config.setBytesPerChecksum(256 * 1024);
+ config.setBytesPerChecksum(16 * 1024);
StreamBufferArgs streamBufferArgs =
StreamBufferArgs.getDefaultStreamBufferArgs(pipeline.getReplicationConfig(),
config);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
