You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2022/09/28 13:00:47 UTC

[accumulo-testing] branch 2.0 updated: Fix Bulk Rwalk (#230)

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

mmiller pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/accumulo-testing.git


The following commit(s) were added to refs/heads/2.0 by this push:
     new 43796e6  Fix Bulk Rwalk (#230)
43796e6 is described below

commit 43796e665b2b45b7f1d5938cd41b221369d1edf2
Author: Mike Miller <mm...@apache.org>
AuthorDate: Mon Sep 26 15:55:40 2022 +0000

    Fix Bulk Rwalk (#230)
---
 .../java/org/apache/accumulo/testing/randomwalk/bulk/BulkPlusOne.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/BulkPlusOne.java b/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/BulkPlusOne.java
index 55d81c1..5d6398e 100644
--- a/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/BulkPlusOne.java
+++ b/src/main/java/org/apache/accumulo/testing/randomwalk/bulk/BulkPlusOne.java
@@ -94,7 +94,7 @@ public class BulkPlusOne extends BulkImportTest {
       writer.close();
     }
     env.getAccumuloClient().tableOperations().importDirectory(dir.toString())
-        .to(Setup.getTableName()).tableTime(true);
+        .to(Setup.getTableName()).tableTime(true).load();
     fs.delete(dir, true);
     log.debug("Finished bulk import, start rows " + printRows + " last row "
         + String.format(FMT, LOTS - 1) + " marker " + markerColumnQualifier);