| commit | 32aba0ef592bd8b40766025d1ed6f64a3c6ccca8 | [log] [tgz] |
|---|---|---|
| author | Mike Miller <mmiller@apache.org> | Thu Sep 12 13:06:55 2019 -0400 |
| committer | Mike Miller <mmiller@apache.org> | Thu Sep 12 13:06:55 2019 -0400 |
| tree | 2888c2c6f18f3dcd8672d4572d20047f7e65f23d | |
| parent | 9ece86d7449a8dde14096451869464a81e8dbc10 [diff] |
Fix BulkImport concurrent rwalk
diff --git a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/BulkImport.java b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/BulkImport.java index 4dd9736..b3ebe27 100644 --- a/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/BulkImport.java +++ b/src/main/java/org/apache/accumulo/testing/randomwalk/concurrent/BulkImport.java
@@ -97,7 +97,7 @@ FileSystem fs = FileSystem.get(env.getHadoopConfiguration()); - String bulkDir = "/tmp/concurrent_bulk/b_" + String bulkDir = env.getHdfsRoot() + "/tmp/concurrent_bulk/b_" + String.format("%016x", rand.nextLong() & 0x7fffffffffffffffl); fs.mkdirs(new Path(bulkDir));