This is an automated email from the ASF dual-hosted git repository.
dlmarion pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/elasticity by this push:
new ce83488245 Reduced number of compactions in CompactionConfigChangeIT
(#4402)
ce83488245 is described below
commit ce834882456546df79e957f2f242adc37d059bdc
Author: Dave Marion <[email protected]>
AuthorDate: Tue Mar 19 12:20:55 2024 -0400
Reduced number of compactions in CompactionConfigChangeIT (#4402)
The test waits for 60s for the number of F files to reach zero.
However, there are 100 files and there is a comment that says
each compaction should take about 1s. I reduced the number of
files from 100 to 50 to allow the test to complete in the allotted
time.
---
.../apache/accumulo/test/compaction/CompactionConfigChangeIT.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/test/src/main/java/org/apache/accumulo/test/compaction/CompactionConfigChangeIT.java
b/test/src/main/java/org/apache/accumulo/test/compaction/CompactionConfigChangeIT.java
index c734493287..fe1783b841 100644
---
a/test/src/main/java/org/apache/accumulo/test/compaction/CompactionConfigChangeIT.java
+++
b/test/src/main/java/org/apache/accumulo/test/compaction/CompactionConfigChangeIT.java
@@ -75,26 +75,26 @@ public class CompactionConfigChangeIT extends
AccumuloClusterHarness {
try (AccumuloClient client =
Accumulo.newClient().from(getClientProps()).build()) {
final String table = getUniqueNames(1)[0];
- createTable(client, table, "cs1", 100);
+ createTable(client, table, "cs1", 50);
ExternalCompactionTestUtils.writeData(client, table, MAX_DATA);
client.tableOperations().flush(table, null, null, true);
- assertEquals(100, countFiles(client, table, "F"));
+ assertEquals(50, countFiles(client, table, "F"));
// Start 100 slow compactions, each compaction should take ~1 second.
There are 2 tservers
// each with 2 threads and then 8 threads.
CompactionConfig compactionConfig = new CompactionConfig();
IteratorSetting iteratorSetting = new IteratorSetting(100,
SlowIterator.class);
- SlowIterator.setSleepTime(iteratorSetting, 100);
+ SlowIterator.setSleepTime(iteratorSetting, 50);
compactionConfig.setIterators(List.of(iteratorSetting));
compactionConfig.setWait(false);
client.tableOperations().compact(table, compactionConfig);
// give some time for compactions to start running
- Wait.waitFor(() -> countFiles(client, table, "F") < 95);
+ Wait.waitFor(() -> countFiles(client, table, "F") < 45);
// Change config deleting groups named small, medium, and large. There
was bug where
// deleting groups running compactions would leave the tablet in a bad
state for future