You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2014/09/15 19:48:07 UTC
[2/2] git commit: ACCUMULO-3117 found some other replication tests
failing with the 50M mutation queue
ACCUMULO-3117 found some other replication tests failing with the 50M mutation queue
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/83ed12ae
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/83ed12ae
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/83ed12ae
Branch: refs/heads/master
Commit: 83ed12ae3729f82ce1307e7fbee3215f1def0298
Parents: dbd7c17
Author: Eric C. Newton <er...@gmail.com>
Authored: Mon Sep 15 13:48:07 2014 -0400
Committer: Eric C. Newton <er...@gmail.com>
Committed: Mon Sep 15 13:48:07 2014 -0400
----------------------------------------------------------------------
.../accumulo/test/replication/MultiInstanceReplicationIT.java | 1 +
.../java/org/apache/accumulo/test/replication/ReplicationIT.java | 1 +
2 files changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/83ed12ae/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
index 29e125c..3c6da2e 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
@@ -95,6 +95,7 @@ public class MultiInstanceReplicationIT extends ConfigurableMacIT {
cfg.setProperty(Property.REPLICATION_MAX_UNIT_SIZE, "8M");
cfg.setProperty(Property.REPLICATION_NAME, "master");
cfg.setProperty(Property.REPLICATION_WORK_ASSIGNER, SequentialWorkAssigner.class.getName());
+ cfg.setProperty(Property.TSERV_TOTAL_MUTATION_QUEUE_MAX, "1M");
hadoopCoreSite.set("fs.file.impl", RawLocalFileSystem.class.getName());
}
http://git-wip-us.apache.org/repos/asf/accumulo/blob/83ed12ae/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
index 2a17d20..3c3a748 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java
@@ -99,6 +99,7 @@ public class ReplicationIT extends ConfigurableMacIT {
cfg.setProperty(Property.REPLICATION_NAME, "master");
cfg.setProperty(Property.REPLICATION_WORK_PROCESSOR_DELAY, "1s");
cfg.setProperty(Property.REPLICATION_WORK_PROCESSOR_PERIOD, "1s");
+ cfg.setProperty(Property.TSERV_TOTAL_MUTATION_QUEUE_MAX, "1M");
cfg.setNumTservers(1);
hadoopCoreSite.set("fs.file.impl", RawLocalFileSystem.class.getName());
}