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);