This is an automated email from the ASF dual-hosted git repository.
ctubbsii pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 46e58fbaf4 Fix BulkNewIT
46e58fbaf4 is described below
commit 46e58fbaf42314dd7e87750772752aa23f4cf1f5
Author: Christopher Tubbs <[email protected]>
AuthorDate: Fri Mar 28 17:45:50 2025 -0400
Fix BulkNewIT
* Add missing filesystem parameter in new test added as part of #5375
---
.../java/org/apache/accumulo/test/functional/BulkNewIT.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
b/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
index f727d0069d..26784ccfb5 100644
--- a/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/functional/BulkNewIT.java
@@ -627,11 +627,11 @@ public class BulkNewIT extends SharedMiniClusterBase {
try (AccumuloClient c =
Accumulo.newClient().from(getClientProps()).build()) {
String dir = getDir("/testManyTablets-");
- writeData(dir + "/f1.", aconf, 0, 199);
- writeData(dir + "/f2.", aconf, 200, 399);
- writeData(dir + "/f3.", aconf, 400, 599);
- writeData(dir + "/f4.", aconf, 600, 799);
- writeData(dir + "/f5.", aconf, 800, 999);
+ writeData(fs, dir + "/f1.", aconf, 0, 199);
+ writeData(fs, dir + "/f2.", aconf, 200, 399);
+ writeData(fs, dir + "/f3.", aconf, 400, 599);
+ writeData(fs, dir + "/f4.", aconf, 600, 799);
+ writeData(fs, dir + "/f5.", aconf, 800, 999);
var splits = IntStream.range(1,
1000).mapToObj(BulkNewIT::row).map(Text::new)
.collect(Collectors.toCollection(TreeSet::new));