commit | 43796e665b2b45b7f1d5938cd41b221369d1edf2 | [log] [tgz] |
---|---|---|
author | Mike Miller <mmiller@apache.org> | Mon Sep 26 15:55:40 2022 +0000 |
committer | Mike Miller <mmiller@apache.org> | Wed Sep 28 07:26:17 2022 -0400 |
tree | 7d1f0a1a44cd587952018ef21e45ab43c2e99344 | |
parent | 41ba8e83114a70fb6aa8340fc332f314d073668e [diff] |
Fix Bulk Rwalk (#230)
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 @@ 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);