diff --git a/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandIntegrationTest.java b/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandIntegrationTest.java index 4e226dd7acea..00410ab8354e 100644 --- a/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandIntegrationTest.java +++ b/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandIntegrationTest.java @@ -110,5 +110,8 @@ public void testRegxPatternFileFilter() throws Exception { Thread.sleep(1000); } assertTrue(mOutput.toString().contains("Inodes Processed: 1")); + assertEquals(0, mFileSystem.getStatus(uriA).getInAlluxioPercentage()); + assertEquals(100, mFileSystem.getStatus(uriB).getInAlluxioPercentage()); + assertEquals(0, mFileSystem.getStatus(uriC).getInAlluxioPercentage()); } } diff --git a/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandWithVirtualBlockIntegrationTest.java b/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandWithVirtualBlockIntegrationTest.java index 104c1a2dc692..308cf1298fe2 100644 --- a/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandWithVirtualBlockIntegrationTest.java +++ b/dora/tests/integration/src/test/java/alluxio/client/cli/fs/command/DoraLoadCommandWithVirtualBlockIntegrationTest.java @@ -37,7 +37,7 @@ public DoraLoadCommandWithVirtualBlockIntegrationTest() throws IOException { @Override public void before() throws Exception { mLocalAlluxioClusterResource.setProperty(PropertyKey.MASTER_SCHEDULER_INITIAL_DELAY, "1s") - .setProperty(PropertyKey.DORA_READ_VIRTUAL_BLOCK_SIZE, "30MB") + .setProperty(PropertyKey.DORA_READ_VIRTUAL_BLOCK_SIZE, "2MB") .setProperty(PropertyKey.UNDERFS_XATTR_CHANGE_ENABLED, false); super.before(); } @@ -48,11 +48,11 @@ public void testCommand() throws Exception { String path = testRoot.getAbsolutePath(); mTestFolder.newFolder("testRoot/testDirectory"); - int lengthA = 16 * Constants.MB; + int lengthA = 1 * Constants.MB; createByteFileInUfs("/testRoot/testFileA", lengthA); - int lengthB = 32 * Constants.MB; + int lengthB = 3 * Constants.MB; createByteFileInUfs("/testRoot/testFileB", lengthB); - int lengthC = 64 * Constants.MB; + int lengthC = 5 * Constants.MB; createByteFileInUfs("/testRoot/testDirectory/testFileC", lengthC); AlluxioURI uriA = new AlluxioURI("/testRoot/testFileA");