You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hdfs-commits@hadoop.apache.org by ms...@apache.org on 2019/10/21 00:58:08 UTC

[hadoop-ozone] branch master updated: HDDS-2336. Fix TestKeyValueContainer#testRocksDBCreateUsesCachedOptions. Contributed by Attila Doroszlai. (#63)

This is an automated email from the ASF dual-hosted git repository.

msingh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git


The following commit(s) were added to refs/heads/master by this push:
     new aaa333c  HDDS-2336. Fix TestKeyValueContainer#testRocksDBCreateUsesCachedOptions. Contributed by  Attila Doroszlai.  (#63)
aaa333c is described below

commit aaa333c886660b2a4e698ccc500aaa9febeb78d0
Author: Doroszlai, Attila <64...@users.noreply.github.com>
AuthorDate: Mon Oct 21 02:57:59 2019 +0200

    HDDS-2336. Fix TestKeyValueContainer#testRocksDBCreateUsesCachedOptions. Contributed by  Attila Doroszlai.  (#63)
---
 .../container/keyvalue/TestKeyValueContainer.java  | 23 +++++++++++-----------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java
index ac369aa..8597f22 100644
--- a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java
+++ b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java
@@ -63,6 +63,7 @@ import static java.nio.charset.StandardCharsets.UTF_8;
 import static org.apache.ratis.util.Preconditions.assertTrue;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertSame;
 import static org.junit.Assert.fail;
 import static org.mockito.ArgumentMatchers.anyList;
 import static org.mockito.ArgumentMatchers.anyLong;
@@ -232,18 +233,18 @@ public class TestKeyValueContainer {
       container.importContainerData(fis, packer);
     }
 
-    Assert.assertEquals("value1", containerData.getMetadata().get("key1"));
-    Assert.assertEquals(keyValueContainerData.getContainerDBType(),
+    assertEquals("value1", containerData.getMetadata().get("key1"));
+    assertEquals(keyValueContainerData.getContainerDBType(),
         containerData.getContainerDBType());
-    Assert.assertEquals(keyValueContainerData.getState(),
+    assertEquals(keyValueContainerData.getState(),
         containerData.getState());
-    Assert.assertEquals(numberOfKeysToWrite,
+    assertEquals(numberOfKeysToWrite,
         containerData.getKeyCount());
-    Assert.assertEquals(keyValueContainerData.getLayOutVersion(),
+    assertEquals(keyValueContainerData.getLayOutVersion(),
         containerData.getLayOutVersion());
-    Assert.assertEquals(keyValueContainerData.getMaxSize(),
+    assertEquals(keyValueContainerData.getMaxSize(),
         containerData.getMaxSize());
-    Assert.assertEquals(keyValueContainerData.getBytesUsed(),
+    assertEquals(keyValueContainerData.getBytesUsed(),
         containerData.getBytesUsed());
 
     //Can't overwrite existing container
@@ -388,6 +389,8 @@ public class TestKeyValueContainer {
 
   @Test
   public void testRocksDBCreateUsesCachedOptions() throws Exception {
+    int initialSize = MetadataStoreBuilder.CACHED_OPTS.size();
+
     // Create Container 1
     keyValueContainer.create(volumeSet, volumeChoosingPolicy, scmId);
     Assert.assertTrue("Rocks DB options should be cached.",
@@ -403,10 +406,8 @@ public class TestKeyValueContainer {
     keyValueContainer = new KeyValueContainer(keyValueContainerData, conf);
     keyValueContainer.create(volumeSet, volumeChoosingPolicy, scmId);
 
-    Assert.assertEquals(1, MetadataStoreBuilder.CACHED_OPTS.size());
+    assertEquals(initialSize + 1, MetadataStoreBuilder.CACHED_OPTS.size());
     Options cachedOpts = MetadataStoreBuilder.CACHED_OPTS.get(conf);
-    Assert.assertEquals("Cache object should not be updated.",
-        opts, cachedOpts);
-
+    assertSame("Cache object should not be updated.", opts, cachedOpts);
   }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: hdfs-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: hdfs-commits-help@hadoop.apache.org